Documentation
¶
Index ¶
- Variables
- type BaseMessage
- func (*BaseMessage) Descriptor() ([]byte, []int)deprecated
- func (x *BaseMessage) GetLabels() map[string]string
- func (x *BaseMessage) GetMsg() string
- func (x *BaseMessage) GetTimestamp() string
- func (*BaseMessage) ProtoMessage()
- func (x *BaseMessage) ProtoReflect() protoreflect.Message
- func (x *BaseMessage) Reset()
- func (x *BaseMessage) String() string
- type TestCustomMessage
- func (*TestCustomMessage) Descriptor() ([]byte, []int)deprecated
- func (x *TestCustomMessage) GetBoolVal() bool
- func (x *TestCustomMessage) GetBytesVal() []byte
- func (x *TestCustomMessage) GetFloatVal() float32
- func (x *TestCustomMessage) GetIntVal() int64
- func (x *TestCustomMessage) GetStringVal() string
- func (*TestCustomMessage) ProtoMessage()
- func (x *TestCustomMessage) ProtoReflect() protoreflect.Message
- func (x *TestCustomMessage) Reset()
- func (x *TestCustomMessage) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_beholder_pb_base_message_proto protoreflect.FileDescriptor
View Source
var File_beholder_pb_example_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BaseMessage ¶ added in v0.4.0
type BaseMessage struct {
Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
// https://protobuf.dev/programming-guides/proto3/#maps
// In go: if Value is empty for a key, nothing will be serialized
Labels map[string]string `` /* 139-byte string literal not displayed */
// timestamp is set by the BaseMessage consumer.
// Ingestion timestamps should be applied downstream.
// Consumers composing BaseMessage are allowed to set timestamp,
// but downstream data consumers should respect the outermost message.
Timestamp string `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// contains filtered or unexported fields
}
BaseMessage is a basic custom message, allowing the consumer to send a string msg with some key-value pairs for labels. Consumers can consume BaseMessage directly or extend it by adding use-case specific fields NOTE: do not compose protos for Beholder until INFOPLAT-1386 is completed
func (*BaseMessage) Descriptor
deprecated
added in
v0.4.0
func (*BaseMessage) Descriptor() ([]byte, []int)
Deprecated: Use BaseMessage.ProtoReflect.Descriptor instead.
func (*BaseMessage) GetLabels ¶ added in v0.4.0
func (x *BaseMessage) GetLabels() map[string]string
func (*BaseMessage) GetMsg ¶ added in v0.4.0
func (x *BaseMessage) GetMsg() string
func (*BaseMessage) GetTimestamp ¶ added in v0.7.1
func (x *BaseMessage) GetTimestamp() string
func (*BaseMessage) ProtoMessage ¶ added in v0.4.0
func (*BaseMessage) ProtoMessage()
func (*BaseMessage) ProtoReflect ¶ added in v0.4.0
func (x *BaseMessage) ProtoReflect() protoreflect.Message
func (*BaseMessage) Reset ¶ added in v0.4.0
func (x *BaseMessage) Reset()
func (*BaseMessage) String ¶ added in v0.4.0
func (x *BaseMessage) String() string
type TestCustomMessage ¶
type TestCustomMessage struct {
BoolVal bool `protobuf:"varint,1,opt,name=bool_val,json=boolVal,proto3" json:"bool_val,omitempty"`
IntVal int64 `protobuf:"varint,2,opt,name=int_val,json=intVal,proto3" json:"int_val,omitempty"`
FloatVal float32 `protobuf:"fixed32,3,opt,name=float_val,json=floatVal,proto3" json:"float_val,omitempty"`
StringVal string `protobuf:"bytes,4,opt,name=string_val,json=stringVal,proto3" json:"string_val,omitempty"`
BytesVal []byte `protobuf:"bytes,5,opt,name=bytes_val,json=bytesVal,proto3" json:"bytes_val,omitempty"`
// contains filtered or unexported fields
}
Used for testing
func (*TestCustomMessage) Descriptor
deprecated
func (*TestCustomMessage) Descriptor() ([]byte, []int)
Deprecated: Use TestCustomMessage.ProtoReflect.Descriptor instead.
func (*TestCustomMessage) GetBoolVal ¶
func (x *TestCustomMessage) GetBoolVal() bool
func (*TestCustomMessage) GetBytesVal ¶
func (x *TestCustomMessage) GetBytesVal() []byte
func (*TestCustomMessage) GetFloatVal ¶
func (x *TestCustomMessage) GetFloatVal() float32
func (*TestCustomMessage) GetIntVal ¶
func (x *TestCustomMessage) GetIntVal() int64
func (*TestCustomMessage) GetStringVal ¶
func (x *TestCustomMessage) GetStringVal() string
func (*TestCustomMessage) ProtoMessage ¶
func (*TestCustomMessage) ProtoMessage()
func (*TestCustomMessage) ProtoReflect ¶
func (x *TestCustomMessage) ProtoReflect() protoreflect.Message
func (*TestCustomMessage) Reset ¶
func (x *TestCustomMessage) Reset()
func (*TestCustomMessage) String ¶
func (x *TestCustomMessage) String() string
Click to show internal directories.
Click to hide internal directories.