p2pb

Documentation

Index

• Variables
• type PeerInfo
  • func (*PeerInfo) Descriptor() ([]byte, []int)
  • func (m *PeerInfo) GetAddrs() []string
  • func (m *PeerInfo) GetId() string
  • func (m *PeerInfo) Marshal() (dAtA []byte, err error)
  • func (m *PeerInfo) MarshalTo(dAtA []byte) (int, error)
  • func (*PeerInfo) ProtoMessage()
  • func (m *PeerInfo) Reset()
  • func (m *PeerInfo) Size() (n int)
  • func (m *PeerInfo) String() string
  • func (m *PeerInfo) Unmarshal(dAtA []byte) error
  • func (m *PeerInfo) XXX_DiscardUnknown()
  • func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *PeerInfo) XXX_Merge(src proto.Message)
  • func (m *PeerInfo) XXX_Size() int
  • func (m *PeerInfo) XXX_Unmarshal(b []byte) error
• type RoutingQuery
  • func (*RoutingQuery) Descriptor() ([]byte, []int)
  • func (m *RoutingQuery) GetIds() []string
  • func (m *RoutingQuery) Marshal() (dAtA []byte, err error)
  • func (m *RoutingQuery) MarshalTo(dAtA []byte) (int, error)
  • func (*RoutingQuery) ProtoMessage()
  • func (m *RoutingQuery) Reset()
  • func (m *RoutingQuery) Size() (n int)
  • func (m *RoutingQuery) String() string
  • func (m *RoutingQuery) Unmarshal(dAtA []byte) error
  • func (m *RoutingQuery) XXX_DiscardUnknown()
  • func (m *RoutingQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *RoutingQuery) XXX_Merge(src proto.Message)
  • func (m *RoutingQuery) XXX_Size() int
  • func (m *RoutingQuery) XXX_Unmarshal(b []byte) error
• type RoutingResponse
  • func (*RoutingResponse) Descriptor() ([]byte, []int)
  • func (m *RoutingResponse) GetPeers() []*PeerInfo
  • func (m *RoutingResponse) Marshal() (dAtA []byte, err error)
  • func (m *RoutingResponse) MarshalTo(dAtA []byte) (int, error)
  • func (*RoutingResponse) ProtoMessage()
  • func (m *RoutingResponse) Reset()
  • func (m *RoutingResponse) Size() (n int)
  • func (m *RoutingResponse) String() string
  • func (m *RoutingResponse) Unmarshal(dAtA []byte) error
  • func (m *RoutingResponse) XXX_DiscardUnknown()
  • func (m *RoutingResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *RoutingResponse) XXX_Merge(src proto.Message)
  • func (m *RoutingResponse) XXX_Size() int
  • func (m *RoutingResponse) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage   = fmt.Errorf("proto: integer overflow")
)

Types

type PeerInfo

type PeerInfo struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Addrs                []string `protobuf:"bytes,2,rep,name=addrs" json:"addrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerInfo) Descriptor

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

func (*PeerInfo) GetAddrs

func (m *PeerInfo) GetAddrs() []string

func (*PeerInfo) GetId

func (m *PeerInfo) GetId() string

func (*PeerInfo) Marshal

func (m *PeerInfo) Marshal() (dAtA []byte, err error)

func (*PeerInfo) MarshalTo

func (m *PeerInfo) MarshalTo(dAtA []byte) (int, error)

func (*PeerInfo) ProtoMessage

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset

func (m *PeerInfo) Reset()

func (*PeerInfo) Size

func (m *PeerInfo) Size() (n int)

func (*PeerInfo) String

func (m *PeerInfo) String() string

func (*PeerInfo) Unmarshal

func (m *PeerInfo) Unmarshal(dAtA []byte) error

func (*PeerInfo) XXX_DiscardUnknown

func (m *PeerInfo) XXX_DiscardUnknown()

func (*PeerInfo) XXX_Marshal

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

func (*PeerInfo) XXX_Merge

func (dst *PeerInfo) XXX_Merge(src proto.Message)

func (*PeerInfo) XXX_Size

func (m *PeerInfo) XXX_Size() int

func (*PeerInfo) XXX_Unmarshal

func (m *PeerInfo) XXX_Unmarshal(b []byte) error

type RoutingQuery

type RoutingQuery struct {
	Ids                  []string `protobuf:"bytes,1,rep,name=ids" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RoutingQuery) Descriptor

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

func (*RoutingQuery) GetIds

func (m *RoutingQuery) GetIds() []string

func (*RoutingQuery) Marshal

func (m *RoutingQuery) Marshal() (dAtA []byte, err error)

func (*RoutingQuery) MarshalTo

func (m *RoutingQuery) MarshalTo(dAtA []byte) (int, error)

func (*RoutingQuery) ProtoMessage

func (*RoutingQuery) ProtoMessage()

func (*RoutingQuery) Reset

func (m *RoutingQuery) Reset()

func (*RoutingQuery) Size

func (m *RoutingQuery) Size() (n int)

func (*RoutingQuery) String

func (m *RoutingQuery) String() string

func (*RoutingQuery) Unmarshal

func (m *RoutingQuery) Unmarshal(dAtA []byte) error

func (*RoutingQuery) XXX_DiscardUnknown

func (m *RoutingQuery) XXX_DiscardUnknown()

func (*RoutingQuery) XXX_Marshal

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

func (*RoutingQuery) XXX_Merge

func (dst *RoutingQuery) XXX_Merge(src proto.Message)

func (*RoutingQuery) XXX_Size

func (m *RoutingQuery) XXX_Size() int

func (*RoutingQuery) XXX_Unmarshal

func (m *RoutingQuery) XXX_Unmarshal(b []byte) error

type RoutingResponse

type RoutingResponse struct {
	Peers                []*PeerInfo `protobuf:"bytes,1,rep,name=peers" json:"peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RoutingResponse) Descriptor

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

func (*RoutingResponse) GetPeers

func (m *RoutingResponse) GetPeers() []*PeerInfo

func (*RoutingResponse) Marshal

func (m *RoutingResponse) Marshal() (dAtA []byte, err error)

func (*RoutingResponse) MarshalTo

func (m *RoutingResponse) MarshalTo(dAtA []byte) (int, error)

func (*RoutingResponse) ProtoMessage

func (*RoutingResponse) ProtoMessage()

func (*RoutingResponse) Reset

func (m *RoutingResponse) Reset()

func (*RoutingResponse) Size

func (m *RoutingResponse) Size() (n int)

func (*RoutingResponse) String

func (m *RoutingResponse) String() string

func (*RoutingResponse) Unmarshal

func (m *RoutingResponse) Unmarshal(dAtA []byte) error

func (*RoutingResponse) XXX_DiscardUnknown

func (m *RoutingResponse) XXX_DiscardUnknown()

func (*RoutingResponse) XXX_Marshal

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

func (*RoutingResponse) XXX_Merge

func (dst *RoutingResponse) XXX_Merge(src proto.Message)

func (*RoutingResponse) XXX_Size

func (m *RoutingResponse) XXX_Size() int

func (*RoutingResponse) XXX_Unmarshal

func (m *RoutingResponse) XXX_Unmarshal(b []byte) error