Versions in this module Expand all Collapse all v0 v0.1.0 Aug 3, 2021 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 + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (m *Ack) GetCursors() []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 Cancel struct + Ruid uint32 + func (*Cancel) Descriptor() ([]byte, []int) + func (*Cancel) ProtoMessage() + func (m *Cancel) GetRuid() uint32 + func (m *Cancel) Marshal() (dAtA []byte, err error) + func (m *Cancel) MarshalTo(dAtA []byte) (int, error) + func (m *Cancel) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Cancel) Reset() + func (m *Cancel) Size() (n int) + func (m *Cancel) String() string + func (m *Cancel) Unmarshal(dAtA []byte) error + func (m *Cancel) XXX_DiscardUnknown() + func (m *Cancel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cancel) XXX_Merge(src proto.Message) + func (m *Cancel) XXX_Size() int + func (m *Cancel) 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 GetRange struct + Bin int32 + From uint64 + To uint64 + func (*GetRange) Descriptor() ([]byte, []int) + func (*GetRange) ProtoMessage() + func (m *GetRange) GetBin() int32 + func (m *GetRange) GetFrom() uint64 + func (m *GetRange) GetTo() uint64 + func (m *GetRange) Marshal() (dAtA []byte, err error) + func (m *GetRange) MarshalTo(dAtA []byte) (int, error) + func (m *GetRange) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetRange) Reset() + func (m *GetRange) Size() (n int) + func (m *GetRange) String() string + func (m *GetRange) Unmarshal(dAtA []byte) error + func (m *GetRange) XXX_DiscardUnknown() + func (m *GetRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRange) XXX_Merge(src proto.Message) + func (m *GetRange) XXX_Size() int + func (m *GetRange) XXX_Unmarshal(b []byte) error + type Offer struct + Hashes []byte + Topmost uint64 + func (*Offer) Descriptor() ([]byte, []int) + func (*Offer) ProtoMessage() + func (m *Offer) GetHashes() []byte + 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 Ruid struct + Ruid uint32 + func (*Ruid) Descriptor() ([]byte, []int) + func (*Ruid) ProtoMessage() + func (m *Ruid) GetRuid() uint32 + func (m *Ruid) Marshal() (dAtA []byte, err error) + func (m *Ruid) MarshalTo(dAtA []byte) (int, error) + func (m *Ruid) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Ruid) Reset() + func (m *Ruid) Size() (n int) + func (m *Ruid) String() string + func (m *Ruid) Unmarshal(dAtA []byte) error + func (m *Ruid) XXX_DiscardUnknown() + func (m *Ruid) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ruid) XXX_Merge(src proto.Message) + func (m *Ruid) XXX_Size() int + func (m *Ruid) 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