Versions in this module Expand all Collapse all v0 v0.1.10 Dec 16, 2019 Changes in this version + var ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") + var TicketAck_Type_name = map[int32]string + var TicketAck_Type_value = map[string]int32 + var Ticket_State_name = map[int32]string + var Ticket_State_value = map[string]int32 + type Message struct + Blocks [][]byte + Payload []Message_Block + TicketAcklist []*TicketAck + Ticketlist []*Ticket + Wantlist Message_Wantlist + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetBlocks() [][]byte + func (m *Message) GetPayload() []Message_Block + func (m *Message) GetTicketAcklist() []*TicketAck + func (m *Message) GetTicketlist() []*Ticket + func (m *Message) GetWantlist() Message_Wantlist + func (m *Message) Marshal() (dAtA []byte, err error) + func (m *Message) MarshalTo(dAtA []byte) (int, error) + func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message) Reset() + func (m *Message) Size() (n int) + func (m *Message) String() string + func (m *Message) Unmarshal(dAtA []byte) error + 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 Message_Block struct + Data []byte + Prefix []byte + func (*Message_Block) Descriptor() ([]byte, []int) + func (*Message_Block) ProtoMessage() + func (m *Message_Block) GetData() []byte + func (m *Message_Block) GetPrefix() []byte + func (m *Message_Block) Marshal() (dAtA []byte, err error) + func (m *Message_Block) MarshalTo(dAtA []byte) (int, error) + func (m *Message_Block) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message_Block) Reset() + func (m *Message_Block) Size() (n int) + func (m *Message_Block) String() string + func (m *Message_Block) Unmarshal(dAtA []byte) error + func (m *Message_Block) XXX_DiscardUnknown() + func (m *Message_Block) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message_Block) XXX_Merge(src proto.Message) + func (m *Message_Block) XXX_Size() int + func (m *Message_Block) XXX_Unmarshal(b []byte) error + type Message_Wantlist struct + Entries []Message_Wantlist_Entry + Full bool + func (*Message_Wantlist) Descriptor() ([]byte, []int) + func (*Message_Wantlist) ProtoMessage() + func (m *Message_Wantlist) GetEntries() []Message_Wantlist_Entry + func (m *Message_Wantlist) GetFull() bool + func (m *Message_Wantlist) Marshal() (dAtA []byte, err error) + func (m *Message_Wantlist) MarshalTo(dAtA []byte) (int, error) + func (m *Message_Wantlist) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message_Wantlist) Reset() + func (m *Message_Wantlist) Size() (n int) + func (m *Message_Wantlist) String() string + func (m *Message_Wantlist) Unmarshal(dAtA []byte) error + func (m *Message_Wantlist) XXX_DiscardUnknown() + func (m *Message_Wantlist) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message_Wantlist) XXX_Merge(src proto.Message) + func (m *Message_Wantlist) XXX_Size() int + func (m *Message_Wantlist) XXX_Unmarshal(b []byte) error + type Message_Wantlist_Entry struct + Block []byte + Cancel bool + Priority int32 + func (*Message_Wantlist_Entry) Descriptor() ([]byte, []int) + func (*Message_Wantlist_Entry) ProtoMessage() + func (m *Message_Wantlist_Entry) GetBlock() []byte + func (m *Message_Wantlist_Entry) GetCancel() bool + func (m *Message_Wantlist_Entry) GetPriority() int32 + func (m *Message_Wantlist_Entry) Marshal() (dAtA []byte, err error) + func (m *Message_Wantlist_Entry) MarshalTo(dAtA []byte) (int, error) + func (m *Message_Wantlist_Entry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Message_Wantlist_Entry) Reset() + func (m *Message_Wantlist_Entry) Size() (n int) + func (m *Message_Wantlist_Entry) String() string + func (m *Message_Wantlist_Entry) Unmarshal(dAtA []byte) error + func (m *Message_Wantlist_Entry) XXX_DiscardUnknown() + func (m *Message_Wantlist_Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message_Wantlist_Entry) XXX_Merge(src proto.Message) + func (m *Message_Wantlist_Entry) XXX_Size() int + func (m *Message_Wantlist_Entry) XXX_Unmarshal(b []byte) error + type Ticket struct + ByteSize int64 + Cid string + Publisher string + SendTo string + State Ticket_State + TimeStamp int64 + func (*Ticket) Descriptor() ([]byte, []int) + func (*Ticket) ProtoMessage() + func (m *Ticket) GetByteSize() int64 + func (m *Ticket) GetCid() string + func (m *Ticket) GetPublisher() string + func (m *Ticket) GetSendTo() string + func (m *Ticket) GetState() Ticket_State + func (m *Ticket) GetTimeStamp() int64 + func (m *Ticket) Marshal() (dAtA []byte, err error) + func (m *Ticket) MarshalTo(dAtA []byte) (int, error) + func (m *Ticket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Ticket) Reset() + func (m *Ticket) Size() (n int) + func (m *Ticket) String() string + func (m *Ticket) Unmarshal(dAtA []byte) error + func (m *Ticket) XXX_DiscardUnknown() + func (m *Ticket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ticket) XXX_Merge(src proto.Message) + func (m *Ticket) XXX_Size() int + func (m *Ticket) XXX_Unmarshal(b []byte) error + type TicketAck struct + Cid string + Publisher string + Receiver string + Type TicketAck_Type + func (*TicketAck) Descriptor() ([]byte, []int) + func (*TicketAck) ProtoMessage() + func (m *TicketAck) GetCid() string + func (m *TicketAck) GetPublisher() string + func (m *TicketAck) GetReceiver() string + func (m *TicketAck) GetType() TicketAck_Type + func (m *TicketAck) Marshal() (dAtA []byte, err error) + func (m *TicketAck) MarshalTo(dAtA []byte) (int, error) + func (m *TicketAck) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TicketAck) Reset() + func (m *TicketAck) Size() (n int) + func (m *TicketAck) String() string + func (m *TicketAck) Unmarshal(dAtA []byte) error + func (m *TicketAck) XXX_DiscardUnknown() + func (m *TicketAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TicketAck) XXX_Merge(src proto.Message) + func (m *TicketAck) XXX_Size() int + func (m *TicketAck) XXX_Unmarshal(b []byte) error + type TicketAck_Type int32 + const TicketAck_ACCEPT + const TicketAck_CANCEL + func (TicketAck_Type) EnumDescriptor() ([]byte, []int) + func (x TicketAck_Type) String() string + type TicketAcklist struct + Items []*TicketAck + func (*TicketAcklist) Descriptor() ([]byte, []int) + func (*TicketAcklist) ProtoMessage() + func (m *TicketAcklist) GetItems() []*TicketAck + func (m *TicketAcklist) Marshal() (dAtA []byte, err error) + func (m *TicketAcklist) MarshalTo(dAtA []byte) (int, error) + func (m *TicketAcklist) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TicketAcklist) Reset() + func (m *TicketAcklist) Size() (n int) + func (m *TicketAcklist) String() string + func (m *TicketAcklist) Unmarshal(dAtA []byte) error + func (m *TicketAcklist) XXX_DiscardUnknown() + func (m *TicketAcklist) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TicketAcklist) XXX_Merge(src proto.Message) + func (m *TicketAcklist) XXX_Size() int + func (m *TicketAcklist) XXX_Unmarshal(b []byte) error + type Ticket_State int32 + const Ticket_ACK + const Ticket_CANCEL + const Ticket_New + const Ticket_TIMEOUT + func (Ticket_State) EnumDescriptor() ([]byte, []int) + func (x Ticket_State) String() string + type Ticketlist struct + Items []*Ticket + func (*Ticketlist) Descriptor() ([]byte, []int) + func (*Ticketlist) ProtoMessage() + func (m *Ticketlist) GetItems() []*Ticket + func (m *Ticketlist) Marshal() (dAtA []byte, err error) + func (m *Ticketlist) MarshalTo(dAtA []byte) (int, error) + func (m *Ticketlist) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Ticketlist) Reset() + func (m *Ticketlist) Size() (n int) + func (m *Ticketlist) String() string + func (m *Ticketlist) Unmarshal(dAtA []byte) error + func (m *Ticketlist) XXX_DiscardUnknown() + func (m *Ticketlist) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ticketlist) XXX_Merge(src proto.Message) + func (m *Ticketlist) XXX_Size() int + func (m *Ticketlist) XXX_Unmarshal(b []byte) error v0.1.10-1 Dec 16, 2019