Versions in this module Expand all Collapse all v0 v0.0.3 Apr 21, 2025 v0.0.2 Apr 21, 2025 Changes in this version + var ErrIntOverflowPullsync = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPullsync = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupPullsync = fmt.Errorf("proto: unexpected end of group") + type Ack struct + Cursors []uint64 + Epoch uint64 + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (m *Ack) GetCursors() []uint64 + func (m *Ack) GetEpoch() uint64 + func (m *Ack) Marshal() (dAtA []byte, err error) + func (m *Ack) MarshalTo(dAtA []byte) (int, error) + func (m *Ack) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Ack) Reset() + func (m *Ack) Size() (n int) + func (m *Ack) String() string + func (m *Ack) Unmarshal(dAtA []byte) error + 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 Chunk struct + Address []byte + BatchID []byte + StampHash []byte + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (m *Chunk) GetAddress() []byte + func (m *Chunk) GetBatchID() []byte + func (m *Chunk) GetStampHash() []byte + func (m *Chunk) Marshal() (dAtA []byte, err error) + func (m *Chunk) MarshalTo(dAtA []byte) (int, error) + func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Chunk) Reset() + func (m *Chunk) Size() (n int) + func (m *Chunk) String() string + func (m *Chunk) Unmarshal(dAtA []byte) error + func (m *Chunk) XXX_DiscardUnknown() + func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Chunk) XXX_Merge(src proto.Message) + func (m *Chunk) XXX_Size() int + func (m *Chunk) XXX_Unmarshal(b []byte) error + type Delivery struct + Address []byte + Data []byte + Stamp []byte + func (*Delivery) Descriptor() ([]byte, []int) + func (*Delivery) ProtoMessage() + func (m *Delivery) GetAddress() []byte + func (m *Delivery) GetData() []byte + func (m *Delivery) GetStamp() []byte + func (m *Delivery) Marshal() (dAtA []byte, err error) + func (m *Delivery) MarshalTo(dAtA []byte) (int, error) + func (m *Delivery) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Delivery) Reset() + func (m *Delivery) Size() (n int) + func (m *Delivery) String() string + func (m *Delivery) Unmarshal(dAtA []byte) error + func (m *Delivery) XXX_DiscardUnknown() + func (m *Delivery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Delivery) XXX_Merge(src proto.Message) + func (m *Delivery) XXX_Size() int + func (m *Delivery) XXX_Unmarshal(b []byte) error + type Get struct + Bin int32 + Start uint64 + func (*Get) Descriptor() ([]byte, []int) + func (*Get) ProtoMessage() + func (m *Get) GetBin() int32 + func (m *Get) GetStart() uint64 + func (m *Get) Marshal() (dAtA []byte, err error) + func (m *Get) MarshalTo(dAtA []byte) (int, error) + func (m *Get) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Get) Reset() + func (m *Get) Size() (n int) + func (m *Get) String() string + func (m *Get) Unmarshal(dAtA []byte) error + func (m *Get) XXX_DiscardUnknown() + func (m *Get) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Get) XXX_Merge(src proto.Message) + func (m *Get) XXX_Size() int + func (m *Get) XXX_Unmarshal(b []byte) error + type Offer struct + Chunks []*Chunk + Topmost uint64 + func (*Offer) Descriptor() ([]byte, []int) + func (*Offer) ProtoMessage() + func (m *Offer) GetChunks() []*Chunk + func (m *Offer) GetTopmost() uint64 + func (m *Offer) Marshal() (dAtA []byte, err error) + func (m *Offer) MarshalTo(dAtA []byte) (int, error) + func (m *Offer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Offer) Reset() + func (m *Offer) Size() (n int) + func (m *Offer) String() string + func (m *Offer) Unmarshal(dAtA []byte) error + 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 Syn struct + func (*Syn) Descriptor() ([]byte, []int) + func (*Syn) ProtoMessage() + func (m *Syn) Marshal() (dAtA []byte, err error) + func (m *Syn) MarshalTo(dAtA []byte) (int, error) + func (m *Syn) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Syn) Reset() + func (m *Syn) Size() (n int) + func (m *Syn) String() string + func (m *Syn) Unmarshal(dAtA []byte) error + func (m *Syn) XXX_DiscardUnknown() + func (m *Syn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Syn) XXX_Merge(src proto.Message) + func (m *Syn) XXX_Size() int + func (m *Syn) XXX_Unmarshal(b []byte) error + type Want struct + BitVector []byte + func (*Want) Descriptor() ([]byte, []int) + func (*Want) ProtoMessage() + func (m *Want) GetBitVector() []byte + func (m *Want) Marshal() (dAtA []byte, err error) + func (m *Want) MarshalTo(dAtA []byte) (int, error) + func (m *Want) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Want) Reset() + func (m *Want) Size() (n int) + func (m *Want) String() string + func (m *Want) Unmarshal(dAtA []byte) error + func (m *Want) XXX_DiscardUnknown() + func (m *Want) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Want) XXX_Merge(src proto.Message) + func (m *Want) XXX_Size() int + func (m *Want) XXX_Unmarshal(b []byte) error
Go to main page