protobuf

Jan 11, 2024

Changes in this version

+ var File_sync_proto protoreflect.FileDescriptor

type Message

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

type Offer

+ GroupId []byte

+ MessageIds [][]byte

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

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

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

type Payload

+ GroupOffers []*Offer

+ func (m *Payload) IsValid() bool

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

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

Jul 12, 2019

Changes in this version

type Message

+ func (m Message) ID() state.MessageID

Jun 21, 2019

Changes in this version

type Payload

+ Acks [][]byte

+ Offers [][]byte

+ Requests [][]byte

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

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

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

Jun 10, 2019

Changes in this version

+ type Ack struct

+ Id [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ack) Descriptor() ([]byte, []int)

+ func (*Ack) ProtoMessage()

+ func (m *Ack) GetId() [][]byte

+ func (m *Ack) Reset()

+ func (m *Ack) String() string

+ func (m *Ack) XXX_DiscardUnknown()

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

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

+ func (m *Ack) XXX_Size() int

+ func (m *Ack) XXX_Unmarshal(b []byte) error

+ type Message struct

+ Body []byte

+ GroupId []byte

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Message) ProtoMessage()

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

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

+ func (m *Message) GetTimestamp() int64

+ 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 Offer struct

+ Id [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Offer) ProtoMessage()

+ func (m *Offer) GetId() [][]byte

+ func (m *Offer) Reset()

+ func (m *Offer) String() string

+ func (m *Offer) XXX_DiscardUnknown()

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

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

+ func (m *Offer) XXX_Size() int

+ func (m *Offer) XXX_Unmarshal(b []byte) error

+ type Payload struct

+ Ack *Ack

+ Messages []*Message

+ Offer *Offer

+ Request *Request

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Payload) ProtoMessage()

+ func (m *Payload) GetAck() *Ack

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

+ func (m *Payload) GetOffer() *Offer

+ func (m *Payload) GetRequest() *Request

+ 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

+ type Request struct

+ Id [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Request) Descriptor() ([]byte, []int)

+ func (*Request) ProtoMessage()

+ func (m *Request) GetId() [][]byte

+ func (m *Request) Reset()

+ func (m *Request) String() string

+ func (m *Request) XXX_DiscardUnknown()

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

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

+ func (m *Request) XXX_Size() int

+ func (m *Request) XXX_Unmarshal(b []byte) error