protobuf

package
v0.0.0-...-31600e6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 31, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ValueNull_name = map[int32]string{
	0: "NULL_VALUE",
}
View Source 
var ValueNull_value = map[string]int32{
	"NULL_VALUE": 0,
}

Functions

func ToLogEvent 

func ToLogEvent(l *Log) *event.Event

ToLogEvent returns a log event from a protocol buffer message.

Types

type Log 

type Log struct {
	Object               *ValueObject `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Log) Descriptor 

func (*Log) Descriptor() ([]byte, []int)

func (*Log) GetObject 

func (m *Log) GetObject() *ValueObject

func (*Log) Marshal 

func (m *Log) Marshal() (dAtA []byte, err error)

func (*Log) MarshalTo 

func (m *Log) MarshalTo(dAtA []byte) (int, error)

func (*Log) MarshalToSizedBuffer 

func (m *Log) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) Reset 

func (m *Log) Reset()

func (*Log) Size 

func (m *Log) Size() (n int)

func (*Log) String 

func (m *Log) String() string

func (*Log) Unmarshal 

func (m *Log) Unmarshal(dAtA []byte) error

func (*Log) XXX_DiscardUnknown 

func (m *Log) XXX_DiscardUnknown()

func (*Log) XXX_Marshal 

func (m *Log) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Log) XXX_Merge 

func (m *Log) XXX_Merge(src proto.Message)

func (*Log) XXX_Size 

func (m *Log) XXX_Size() int

func (*Log) XXX_Unmarshal 

func (m *Log) XXX_Unmarshal(b []byte) error

type MessageWrapper 

type MessageWrapper struct {
	// Types that are valid to be assigned to Message:
	//	*MessageWrapper_Log
	Message              isMessageWrapper_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func FromEvent 

func FromEvent(evt *event.Event) *MessageWrapper

FromEvent returns a protocol buffer message containing the log event.

func (*MessageWrapper) Descriptor 

func (*MessageWrapper) Descriptor() ([]byte, []int)

func (*MessageWrapper) GetLog 

func (m *MessageWrapper) GetLog() *Log

func (*MessageWrapper) GetMessage 

func (m *MessageWrapper) GetMessage() isMessageWrapper_Message

func (*MessageWrapper) Marshal 

func (m *MessageWrapper) Marshal() (dAtA []byte, err error)

func (*MessageWrapper) MarshalTo 

func (m *MessageWrapper) MarshalTo(dAtA []byte) (int, error)

func (*MessageWrapper) MarshalToSizedBuffer 

func (m *MessageWrapper) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MessageWrapper) ProtoMessage 

func (*MessageWrapper) ProtoMessage()

func (*MessageWrapper) Reset 

func (m *MessageWrapper) Reset()

func (*MessageWrapper) Size 

func (m *MessageWrapper) Size() (n int)

func (*MessageWrapper) String 

func (m *MessageWrapper) String() string

func (*MessageWrapper) Unmarshal 

func (m *MessageWrapper) Unmarshal(dAtA []byte) error

func (*MessageWrapper) XXX_DiscardUnknown 

func (m *MessageWrapper) XXX_DiscardUnknown()

func (*MessageWrapper) XXX_Marshal 

func (m *MessageWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageWrapper) XXX_Merge 

func (m *MessageWrapper) XXX_Merge(src proto.Message)

func (*MessageWrapper) XXX_OneofWrappers 

func (*MessageWrapper) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MessageWrapper) XXX_Size 

func (m *MessageWrapper) XXX_Size() int

func (*MessageWrapper) XXX_Unmarshal 

func (m *MessageWrapper) XXX_Unmarshal(b []byte) error

type MessageWrapper_Log 

type MessageWrapper_Log struct {
	Log *Log `protobuf:"bytes,1,opt,name=log,proto3,oneof" json:"log,omitempty"`
}

func (*MessageWrapper_Log) MarshalTo 

func (m *MessageWrapper_Log) MarshalTo(dAtA []byte) (int, error)

func (*MessageWrapper_Log) MarshalToSizedBuffer 

func (m *MessageWrapper_Log) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MessageWrapper_Log) Size 

func (m *MessageWrapper_Log) Size() (n int)

type Value 

type Value struct {
	// Types that are valid to be assigned to Kind:
	//	*Value_Null
	//	*Value_Array
	//	*Value_Boolean
	//	*Value_Float
	//	*Value_Integer
	//	*Value_Object
	//	*Value_String_
	//	*Value_Timestamp
	//	*Value_UnsignedInteger
	Kind                 isValue_Kind `protobuf_oneof:"kind"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Value) Descriptor 

func (*Value) Descriptor() ([]byte, []int)

func (*Value) GetArray 

func (m *Value) GetArray() *ValueArray

func (*Value) GetBoolean 

func (m *Value) GetBoolean() bool

func (*Value) GetFloat 

func (m *Value) GetFloat() float64

func (*Value) GetInteger 

func (m *Value) GetInteger() int64

func (*Value) GetKind 

func (m *Value) GetKind() isValue_Kind

func (*Value) GetNull 

func (m *Value) GetNull() ValueNull

func (*Value) GetObject 

func (m *Value) GetObject() *ValueObject

func (*Value) GetString_ 

func (m *Value) GetString_() []byte

func (*Value) GetTimestamp 

func (m *Value) GetTimestamp() int64

func (*Value) GetUnsignedInteger 

func (m *Value) GetUnsignedInteger() uint64

func (*Value) Marshal 

func (m *Value) Marshal() (dAtA []byte, err error)

func (*Value) MarshalTo 

func (m *Value) MarshalTo(dAtA []byte) (int, error)

func (*Value) MarshalToSizedBuffer 

func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) Size 

func (m *Value) Size() (n int)

func (*Value) String 

func (m *Value) String() string

func (*Value) Unmarshal 

func (m *Value) Unmarshal(dAtA []byte) error

func (*Value) XXX_DiscardUnknown 

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal 

func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Value) XXX_Merge 

func (m *Value) XXX_Merge(src proto.Message)

func (*Value) XXX_OneofWrappers 

func (*Value) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Value) XXX_Size 

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal 

func (m *Value) XXX_Unmarshal(b []byte) error

type ValueArray 

type ValueArray struct {
	Items                []*Value `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ValueArray) Descriptor 

func (*ValueArray) Descriptor() ([]byte, []int)

func (*ValueArray) GetItems 

func (m *ValueArray) GetItems() []*Value

func (*ValueArray) Marshal 

func (m *ValueArray) Marshal() (dAtA []byte, err error)

func (*ValueArray) MarshalTo 

func (m *ValueArray) MarshalTo(dAtA []byte) (int, error)

func (*ValueArray) MarshalToSizedBuffer 

func (m *ValueArray) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValueArray) ProtoMessage 

func (*ValueArray) ProtoMessage()

func (*ValueArray) Reset 

func (m *ValueArray) Reset()

func (*ValueArray) Size 

func (m *ValueArray) Size() (n int)

func (*ValueArray) String 

func (m *ValueArray) String() string

func (*ValueArray) Unmarshal 

func (m *ValueArray) Unmarshal(dAtA []byte) error

func (*ValueArray) XXX_DiscardUnknown 

func (m *ValueArray) XXX_DiscardUnknown()

func (*ValueArray) XXX_Marshal 

func (m *ValueArray) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueArray) XXX_Merge 

func (m *ValueArray) XXX_Merge(src proto.Message)

func (*ValueArray) XXX_Size 

func (m *ValueArray) XXX_Size() int

func (*ValueArray) XXX_Unmarshal 

func (m *ValueArray) XXX_Unmarshal(b []byte) error

type ValueNull 

type ValueNull int32

`ValueNull` is a singleton enumeration to represent the null value for the `Value` type union. 

const (
	// Null value.
	ValueNull_NULL_VALUE ValueNull = 0
)

func (ValueNull) EnumDescriptor 

func (ValueNull) EnumDescriptor() ([]byte, []int)

func (ValueNull) String 

func (x ValueNull) String() string

type ValueObject 

type ValueObject struct {
	Fields               map[string]*Value `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ValueObject) Descriptor 

func (*ValueObject) Descriptor() ([]byte, []int)

func (*ValueObject) GetFields 

func (m *ValueObject) GetFields() map[string]*Value

func (*ValueObject) Marshal 

func (m *ValueObject) Marshal() (dAtA []byte, err error)

func (*ValueObject) MarshalTo 

func (m *ValueObject) MarshalTo(dAtA []byte) (int, error)

func (*ValueObject) MarshalToSizedBuffer 

func (m *ValueObject) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ValueObject) ProtoMessage 

func (*ValueObject) ProtoMessage()

func (*ValueObject) Reset 

func (m *ValueObject) Reset()

func (*ValueObject) Size 

func (m *ValueObject) Size() (n int)

func (*ValueObject) String 

func (m *ValueObject) String() string

func (*ValueObject) Unmarshal 

func (m *ValueObject) Unmarshal(dAtA []byte) error

func (*ValueObject) XXX_DiscardUnknown 

func (m *ValueObject) XXX_DiscardUnknown()

func (*ValueObject) XXX_Marshal 

func (m *ValueObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValueObject) XXX_Merge 

func (m *ValueObject) XXX_Merge(src proto.Message)

func (*ValueObject) XXX_Size 

func (m *ValueObject) XXX_Size() int

func (*ValueObject) XXX_Unmarshal 

func (m *ValueObject) XXX_Unmarshal(b []byte) error

type Value_Array 

type Value_Array struct {
	Array *ValueArray `protobuf:"bytes,2,opt,name=array,proto3,oneof" json:"array,omitempty"`
}

func (*Value_Array) MarshalTo 

func (m *Value_Array) MarshalTo(dAtA []byte) (int, error)

func (*Value_Array) MarshalToSizedBuffer 

func (m *Value_Array) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_Array) Size 

func (m *Value_Array) Size() (n int)

type Value_Boolean 

type Value_Boolean struct {
	Boolean bool `protobuf:"varint,3,opt,name=boolean,proto3,oneof" json:"boolean,omitempty"`
}

func (*Value_Boolean) MarshalTo 

func (m *Value_Boolean) MarshalTo(dAtA []byte) (int, error)

func (*Value_Boolean) MarshalToSizedBuffer 

func (m *Value_Boolean) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_Boolean) Size 

func (m *Value_Boolean) Size() (n int)

type Value_Float 

type Value_Float struct {
	Float float64 `protobuf:"fixed64,4,opt,name=float,proto3,oneof" json:"float,omitempty"`
}

func (*Value_Float) MarshalTo 

func (m *Value_Float) MarshalTo(dAtA []byte) (int, error)

func (*Value_Float) MarshalToSizedBuffer 

func (m *Value_Float) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_Float) Size 

func (m *Value_Float) Size() (n int)

type Value_Integer 

type Value_Integer struct {
	Integer int64 `protobuf:"varint,5,opt,name=integer,proto3,oneof" json:"integer,omitempty"`
}

func (*Value_Integer) MarshalTo 

func (m *Value_Integer) MarshalTo(dAtA []byte) (int, error)

func (*Value_Integer) MarshalToSizedBuffer 

func (m *Value_Integer) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_Integer) Size 

func (m *Value_Integer) Size() (n int)

type Value_Null 

type Value_Null struct {
	Null ValueNull `protobuf:"varint,1,opt,name=null,proto3,enum=protobuf.ValueNull,oneof" json:"null,omitempty"`
}

func (*Value_Null) MarshalTo 

func (m *Value_Null) MarshalTo(dAtA []byte) (int, error)

func (*Value_Null) MarshalToSizedBuffer 

func (m *Value_Null) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_Null) Size 

func (m *Value_Null) Size() (n int)

type Value_Object 

type Value_Object struct {
	Object *ValueObject `protobuf:"bytes,6,opt,name=object,proto3,oneof" json:"object,omitempty"`
}

func (*Value_Object) MarshalTo 

func (m *Value_Object) MarshalTo(dAtA []byte) (int, error)

func (*Value_Object) MarshalToSizedBuffer 

func (m *Value_Object) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_Object) Size 

func (m *Value_Object) Size() (n int)

type Value_String_ 

type Value_String_ struct {
	String_ []byte `protobuf:"bytes,7,opt,name=string,proto3,oneof" json:"string,omitempty"`
}

func (*Value_String_) MarshalTo 

func (m *Value_String_) MarshalTo(dAtA []byte) (int, error)

func (*Value_String_) MarshalToSizedBuffer 

func (m *Value_String_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_String_) Size 

func (m *Value_String_) Size() (n int)

type Value_Timestamp 

type Value_Timestamp struct {
	Timestamp int64 `protobuf:"varint,8,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
}

func (*Value_Timestamp) MarshalTo 

func (m *Value_Timestamp) MarshalTo(dAtA []byte) (int, error)

func (*Value_Timestamp) MarshalToSizedBuffer 

func (m *Value_Timestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_Timestamp) Size 

func (m *Value_Timestamp) Size() (n int)

type Value_UnsignedInteger 

type Value_UnsignedInteger struct {
	UnsignedInteger uint64 `protobuf:"varint,9,opt,name=unsigned_integer,json=unsignedInteger,proto3,oneof" json:"unsigned_integer,omitempty"`
}

func (*Value_UnsignedInteger) MarshalTo 

func (m *Value_UnsignedInteger) MarshalTo(dAtA []byte) (int, error)

func (*Value_UnsignedInteger) MarshalToSizedBuffer 

func (m *Value_UnsignedInteger) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Value_UnsignedInteger) Size 

func (m *Value_UnsignedInteger) Size() (n int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.