protobuf

package
v0.0.20 Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2023 License: GPL-3.0 Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_protobuf_join_proto protoreflect.FileDescriptor
View Source 
var File_protobuf_message_proto protoreflect.FileDescriptor
View Source 
var File_protobuf_results_proto protoreflect.FileDescriptor
View Source 
var File_protobuf_state_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types 

type Header struct {
	Headers [][]byte `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetHeaders 

func (x *Header) GetHeaders() [][]byte

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

func (x *Header) ProtoReflect() protoreflect.Message

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type JoinKey 

type JoinKey struct {
	PersistenceId string `protobuf:"bytes,1,opt,name=persistence_id,json=persistenceId,proto3" json:"persistence_id,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinKey) Descriptor deprecated 

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

Deprecated: Use JoinKey.ProtoReflect.Descriptor instead.

func (*JoinKey) GetPersistenceId 

func (x *JoinKey) GetPersistenceId() string

func (*JoinKey) ProtoMessage 

func (*JoinKey) ProtoMessage()

func (*JoinKey) ProtoReflect 

func (x *JoinKey) ProtoReflect() protoreflect.Message

func (*JoinKey) Reset 

func (x *JoinKey) Reset()

func (*JoinKey) String 

func (x *JoinKey) String() string

type Message 

type Message struct {
	Topic     string                 `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition int32                  `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    int64                  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Key       []byte                 `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte                 `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	Headers   map[string]*Header     `` /* 155-byte string literal not displayed */
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetHeaders 

func (x *Message) GetHeaders() map[string]*Header

func (*Message) GetKey 

func (x *Message) GetKey() []byte

func (*Message) GetOffset 

func (x *Message) GetOffset() int64

func (*Message) GetPartition 

func (x *Message) GetPartition() int32

func (*Message) GetTimestamp 

func (x *Message) GetTimestamp() *timestamppb.Timestamp

func (*Message) GetTopic 

func (x *Message) GetTopic() string

func (*Message) GetValue 

func (x *Message) GetValue() []byte

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type ResultV1 

type ResultV1 struct {
	Messages [][]byte `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultV1) Descriptor deprecated 

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

Deprecated: Use ResultV1.ProtoReflect.Descriptor instead.

func (*ResultV1) GetMessages 

func (x *ResultV1) GetMessages() [][]byte

func (*ResultV1) ProtoMessage 

func (*ResultV1) ProtoMessage()

func (*ResultV1) ProtoReflect 

func (x *ResultV1) ProtoReflect() protoreflect.Message

func (*ResultV1) Reset 

func (x *ResultV1) Reset()

func (*ResultV1) String 

func (x *ResultV1) String() string

type Results 

type Results struct {

	// Types that are assignable to Result:
	//
	//	*Results_V1
	Result isResults_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*Results) Descriptor deprecated 

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

Deprecated: Use Results.ProtoReflect.Descriptor instead.

func (*Results) GetResult 

func (m *Results) GetResult() isResults_Result

func (*Results) GetV1 

func (x *Results) GetV1() *ResultV1

func (*Results) ProtoMessage 

func (*Results) ProtoMessage()

func (*Results) ProtoReflect 

func (x *Results) ProtoReflect() protoreflect.Message

func (*Results) Reset 

func (x *Results) Reset()

func (*Results) String 

func (x *Results) String() string

type Results_V1 

type Results_V1 struct {
	V1 *ResultV1 `protobuf:"bytes,1,opt,name=v1,proto3,oneof"`
}

type State 

type State struct {

	// Types that are assignable to State:
	//
	//	*State_V1
	State isState_State `protobuf_oneof:"state"`
	// contains filtered or unexported fields
}

func (*State) Descriptor deprecated 

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

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetState 

func (m *State) GetState() isState_State

func (*State) GetV1 

func (x *State) GetV1() *StateV1

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) ProtoReflect 

func (x *State) ProtoReflect() protoreflect.Message

func (*State) Reset 

func (x *State) Reset()

func (*State) String 

func (x *State) String() string

type StateV1 

type StateV1 struct {
	OffsetProgress map[int32]int64 `` /* 193-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StateV1) Descriptor deprecated 

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

Deprecated: Use StateV1.ProtoReflect.Descriptor instead.

func (*StateV1) GetOffsetProgress 

func (x *StateV1) GetOffsetProgress() map[int32]int64

func (*StateV1) ProtoMessage 

func (*StateV1) ProtoMessage()

func (*StateV1) ProtoReflect 

func (x *StateV1) ProtoReflect() protoreflect.Message

func (*StateV1) Reset 

func (x *StateV1) Reset()

func (*StateV1) String 

func (x *StateV1) String() string

type State_V1 

type State_V1 struct {
	V1 *StateV1 `protobuf:"bytes,1,opt,name=v1,proto3,oneof"`
}

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.