protobuf

Documentation

Index

• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetBody() []byte
  • func (m *Message) GetGroupId() []byte
  • func (m *Message) GetMetadata() *Metadata
  • func (m *Message) GetTimestamp() int64
  • func (m Message) ID() state.MessageID
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string
  • func (m *Message) XXX_DiscardUnknown()
  • func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Message) XXX_Merge(src proto.Message)
  • func (m *Message) XXX_Size() int
  • func (m *Message) XXX_Unmarshal(b []byte) error
• type Metadata
  • func (*Metadata) Descriptor() ([]byte, []int)
  • func (m *Metadata) GetEphemeral() bool
  • func (m *Metadata) GetParents() [][]byte
  • func (*Metadata) ProtoMessage()
  • func (m *Metadata) Reset()
  • func (m *Metadata) String() string
  • func (m *Metadata) XXX_DiscardUnknown()
  • func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Metadata) XXX_Merge(src proto.Message)
  • func (m *Metadata) XXX_Size() int
  • func (m *Metadata) XXX_Unmarshal(b []byte) error
• type Payload
  • func (*Payload) Descriptor() ([]byte, []int)
  • func (m *Payload) GetAcks() [][]byte
  • func (m *Payload) GetMessages() []*Message
  • func (m *Payload) GetOffers() [][]byte
  • func (m *Payload) GetRequests() [][]byte
  • func (m *Payload) IsValid() bool
  • func (*Payload) ProtoMessage()
  • func (m *Payload) Reset()
  • func (m *Payload) String() string
  • func (m *Payload) XXX_DiscardUnknown()
  • func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Payload) XXX_Merge(src proto.Message)
  • func (m *Payload) XXX_Size() int
  • func (m *Payload) XXX_Unmarshal(b []byte) error

Types

type Message

type Message struct {
	GroupId              []byte    `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Timestamp            int64     `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Body                 []byte    `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Metadata             *Metadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Message) Descriptor

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

func (*Message) GetBody

func (m *Message) GetBody() []byte

func (*Message) GetGroupId

func (m *Message) GetGroupId() []byte

func (*Message) GetMetadata

func (m *Message) GetMetadata() *Metadata

func (*Message) GetTimestamp

func (m *Message) GetTimestamp() int64

func (Message) ID

func (m Message) ID() state.MessageID

ID creates the MessageID for a Message

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal

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

func (*Message) XXX_Merge

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

func (*Message) XXX_Size

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal

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

type Metadata

type Metadata struct {
	Parents              [][]byte `protobuf:"bytes,1,rep,name=parents,proto3" json:"parents,omitempty"`
	Ephemeral            bool     `protobuf:"varint,2,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metadata) Descriptor

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

func (*Metadata) GetEphemeral

func (m *Metadata) GetEphemeral() bool

func (*Metadata) GetParents

func (m *Metadata) GetParents() [][]byte

func (*Metadata) ProtoMessage

func (*Metadata) ProtoMessage()

func (*Metadata) Reset

func (m *Metadata) Reset()

func (*Metadata) String

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal

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

func (*Metadata) XXX_Merge

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

func (*Metadata) XXX_Size

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal

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

type Payload

type Payload struct {
	Acks                 [][]byte   `protobuf:"bytes,1,rep,name=acks,proto3" json:"acks,omitempty"`
	Offers               [][]byte   `protobuf:"bytes,2,rep,name=offers,proto3" json:"offers,omitempty"`
	Requests             [][]byte   `protobuf:"bytes,3,rep,name=requests,proto3" json:"requests,omitempty"`
	Messages             []*Message `protobuf:"bytes,4,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Payload) Descriptor

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

func (*Payload) GetAcks

func (m *Payload) GetAcks() [][]byte

func (*Payload) GetMessages

func (m *Payload) GetMessages() []*Message

func (*Payload) GetOffers

func (m *Payload) GetOffers() [][]byte

func (*Payload) GetRequests

func (m *Payload) GetRequests() [][]byte

func (*Payload) IsValid

func (m *Payload) IsValid() bool

IsValid checks whether there are any known field in the protobuf message

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) String

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal

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

func (*Payload) XXX_Merge

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

func (*Payload) XXX_Size

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal

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