protobuf

Documentation

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetBody() []byte
  • func (x *Message) GetGroupId() []byte
  • func (x *Message) GetTimestamp() int64
  • func (m Message) ID() state.MessageID
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type Offer
  • func (*Offer) Descriptor() ([]byte, []int)
  • func (x *Offer) GetGroupId() []byte
  • func (x *Offer) GetMessageIds() [][]byte
  • func (*Offer) ProtoMessage()
  • func (x *Offer) ProtoReflect() protoreflect.Message
  • func (x *Offer) Reset()
  • func (x *Offer) String() string
• type Payload
  • func (*Payload) Descriptor() ([]byte, []int)
  • func (x *Payload) GetAcks() [][]byte
  • func (x *Payload) GetGroupOffers() []*Offer
  • func (x *Payload) GetMessages() []*Message
  • func (x *Payload) GetOffers() [][]byte
  • func (x *Payload) GetRequests() [][]byte
  • func (m *Payload) IsValid() bool
  • func (*Payload) ProtoMessage()
  • func (x *Payload) ProtoReflect() protoreflect.Message
  • func (x *Payload) Reset()
  • func (x *Payload) String() string

Variables

var File_sync_proto protoreflect.FileDescriptor

Types

type Message

type Message struct {
	GroupId   []byte `protobuf:"bytes,6001,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Timestamp int64  `protobuf:"varint,6002,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Body      []byte `protobuf:"bytes,6003,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBody

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

func (*Message) GetGroupId

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

func (*Message) GetTimestamp

func (x *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) ProtoReflect

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

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type Offer

type Offer struct {
	GroupId    []byte   `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	MessageIds [][]byte `protobuf:"bytes,2,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Offer) Descriptor

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

Deprecated: Use Offer.ProtoReflect.Descriptor instead.

func (*Offer) GetGroupId

func (x *Offer) GetGroupId() []byte

func (*Offer) GetMessageIds

func (x *Offer) GetMessageIds() [][]byte

func (*Offer) ProtoMessage

func (*Offer) ProtoMessage()

func (*Offer) ProtoReflect

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

func (*Offer) Reset

func (x *Offer) Reset()

func (*Offer) String

func (x *Offer) String() string

type Payload

type Payload struct {
	Acks        [][]byte   `protobuf:"bytes,5001,rep,name=acks,proto3" json:"acks,omitempty"`
	Offers      [][]byte   `protobuf:"bytes,5002,rep,name=offers,proto3" json:"offers,omitempty"`
	Requests    [][]byte   `protobuf:"bytes,5003,rep,name=requests,proto3" json:"requests,omitempty"`
	Messages    []*Message `protobuf:"bytes,5004,rep,name=messages,proto3" json:"messages,omitempty"`
	GroupOffers []*Offer   `protobuf:"bytes,5005,rep,name=group_offers,json=groupOffers,proto3" json:"group_offers,omitempty"`
	// contains filtered or unexported fields
}

func (*Payload) Descriptor

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

Deprecated: Use Payload.ProtoReflect.Descriptor instead.

func (*Payload) GetAcks

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

func (*Payload) GetGroupOffers

func (x *Payload) GetGroupOffers() []*Offer

func (*Payload) GetMessages

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

func (*Payload) GetOffers

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

func (*Payload) GetRequests

func (x *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) ProtoReflect

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

func (*Payload) Reset

func (x *Payload) Reset()

func (*Payload) String

func (x *Payload) String() string