p2pd_pb

package
v0.9.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 16, 2024 License: Apache-2.0, MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthP2Pd        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowP2Pd          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupP2Pd = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ConnManagerRequest_Type_name = map[int32]string{
	0: "TAG_PEER",
	1: "UNTAG_PEER",
	2: "TRIM",
}
View Source 
var ConnManagerRequest_Type_value = map[string]int32{
	"TAG_PEER":   0,
	"UNTAG_PEER": 1,
	"TRIM":       2,
}
View Source 
var DHTRequest_Type_name = map[int32]string{
	0: "FIND_PEER",
	1: "FIND_PEERS_CONNECTED_TO_PEER",
	2: "FIND_PROVIDERS",
	3: "GET_CLOSEST_PEERS",
	4: "GET_PUBLIC_KEY",
	5: "GET_VALUE",
	6: "SEARCH_VALUE",
	7: "PUT_VALUE",
	8: "PROVIDE",
}
View Source 
var DHTRequest_Type_value = map[string]int32{
	"FIND_PEER":                    0,
	"FIND_PEERS_CONNECTED_TO_PEER": 1,
	"FIND_PROVIDERS":               2,
	"GET_CLOSEST_PEERS":            3,
	"GET_PUBLIC_KEY":               4,
	"GET_VALUE":                    5,
	"SEARCH_VALUE":                 6,
	"PUT_VALUE":                    7,
	"PROVIDE":                      8,
}
View Source 
var DHTResponse_Type_name = map[int32]string{
	0: "BEGIN",
	1: "VALUE",
	2: "END",
}
View Source 
var DHTResponse_Type_value = map[string]int32{
	"BEGIN": 0,
	"VALUE": 1,
	"END":   2,
}
View Source 
var PSRequest_Type_name = map[int32]string{
	0: "GET_TOPICS",
	1: "LIST_PEERS",
	2: "PUBLISH",
	3: "SUBSCRIBE",
}
View Source 
var PSRequest_Type_value = map[string]int32{
	"GET_TOPICS": 0,
	"LIST_PEERS": 1,
	"PUBLISH":    2,
	"SUBSCRIBE":  3,
}
View Source 
var Request_Type_name = map[int32]string{
	0: "IDENTIFY",
	1: "CONNECT",
	2: "STREAM_OPEN",
	3: "STREAM_HANDLER",
	4: "DHT",
	5: "LIST_PEERS",
	6: "CONNMANAGER",
	7: "DISCONNECT",
	8: "PUBSUB",
}
View Source 
var Request_Type_value = map[string]int32{
	"IDENTIFY":       0,
	"CONNECT":        1,
	"STREAM_OPEN":    2,
	"STREAM_HANDLER": 3,
	"DHT":            4,
	"LIST_PEERS":     5,
	"CONNMANAGER":    6,
	"DISCONNECT":     7,
	"PUBSUB":         8,
}
View Source 
var Response_Type_name = map[int32]string{
	0: "OK",
	1: "ERROR",
}
View Source 
var Response_Type_value = map[string]int32{
	"OK":    0,
	"ERROR": 1,
}

Functions

This section is empty.

Types

type ConnManagerRequest 

type ConnManagerRequest struct {
	Type                 *ConnManagerRequest_Type `protobuf:"varint,1,req,name=type,enum=p2pd.pb.ConnManagerRequest_Type" json:"type,omitempty"`
	Peer                 []byte                   `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
	Tag                  *string                  `protobuf:"bytes,3,opt,name=tag" json:"tag,omitempty"`
	Weight               *int64                   `protobuf:"varint,4,opt,name=weight" json:"weight,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ConnManagerRequest) Descriptor 

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

func (*ConnManagerRequest) GetPeer 

func (m *ConnManagerRequest) GetPeer() []byte

func (*ConnManagerRequest) GetTag 

func (m *ConnManagerRequest) GetTag() string

func (*ConnManagerRequest) GetType 

func (m *ConnManagerRequest) GetType() ConnManagerRequest_Type

func (*ConnManagerRequest) GetWeight 

func (m *ConnManagerRequest) GetWeight() int64

func (*ConnManagerRequest) Marshal 

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

func (*ConnManagerRequest) MarshalTo 

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

func (*ConnManagerRequest) MarshalToSizedBuffer added in v0.2.3 

func (m *ConnManagerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnManagerRequest) ProtoMessage 

func (*ConnManagerRequest) ProtoMessage()

func (*ConnManagerRequest) Reset 

func (m *ConnManagerRequest) Reset()

func (*ConnManagerRequest) Size 

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

func (*ConnManagerRequest) String 

func (m *ConnManagerRequest) String() string

func (*ConnManagerRequest) Unmarshal 

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

func (*ConnManagerRequest) XXX_DiscardUnknown 

func (m *ConnManagerRequest) XXX_DiscardUnknown()

func (*ConnManagerRequest) XXX_Marshal 

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

func (*ConnManagerRequest) XXX_Merge 

func (m *ConnManagerRequest) XXX_Merge(src proto.Message)

func (*ConnManagerRequest) XXX_Size 

func (m *ConnManagerRequest) XXX_Size() int

func (*ConnManagerRequest) XXX_Unmarshal 

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

type ConnManagerRequest_Type 

type ConnManagerRequest_Type int32
const (
	ConnManagerRequest_TAG_PEER   ConnManagerRequest_Type = 0
	ConnManagerRequest_UNTAG_PEER ConnManagerRequest_Type = 1
	ConnManagerRequest_TRIM       ConnManagerRequest_Type = 2
)

func (ConnManagerRequest_Type) Enum 

func (x ConnManagerRequest_Type) Enum() *ConnManagerRequest_Type

func (ConnManagerRequest_Type) EnumDescriptor 

func (ConnManagerRequest_Type) EnumDescriptor() ([]byte, []int)

func (ConnManagerRequest_Type) String 

func (x ConnManagerRequest_Type) String() string

func (*ConnManagerRequest_Type) UnmarshalJSON 

func (x *ConnManagerRequest_Type) UnmarshalJSON(data []byte) error

type ConnectRequest 

type ConnectRequest struct {
	Peer                 []byte   `protobuf:"bytes,1,req,name=peer" json:"peer,omitempty"`
	Addrs                [][]byte `protobuf:"bytes,2,rep,name=addrs" json:"addrs,omitempty"`
	Timeout              *int64   `protobuf:"varint,3,opt,name=timeout" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) GetAddrs 

func (m *ConnectRequest) GetAddrs() [][]byte

func (*ConnectRequest) GetPeer 

func (m *ConnectRequest) GetPeer() []byte

func (*ConnectRequest) GetTimeout 

func (m *ConnectRequest) GetTimeout() int64

func (*ConnectRequest) Marshal 

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

func (*ConnectRequest) MarshalTo 

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

func (*ConnectRequest) MarshalToSizedBuffer added in v0.2.3 

func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) Size 

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

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal 

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

func (*ConnectRequest) XXX_DiscardUnknown 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal 

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

func (*ConnectRequest) XXX_Merge 

func (m *ConnectRequest) XXX_Merge(src proto.Message)

func (*ConnectRequest) XXX_Size 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal 

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

type DHTRequest 

type DHTRequest struct {
	Type                 *DHTRequest_Type `protobuf:"varint,1,req,name=type,enum=p2pd.pb.DHTRequest_Type" json:"type,omitempty"`
	Peer                 []byte           `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
	Cid                  []byte           `protobuf:"bytes,3,opt,name=cid" json:"cid,omitempty"`
	Key                  []byte           `protobuf:"bytes,4,opt,name=key" json:"key,omitempty"`
	Value                []byte           `protobuf:"bytes,5,opt,name=value" json:"value,omitempty"`
	Count                *int32           `protobuf:"varint,6,opt,name=count" json:"count,omitempty"`
	Timeout              *int64           `protobuf:"varint,7,opt,name=timeout" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DHTRequest) Descriptor 

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

func (*DHTRequest) GetCid 

func (m *DHTRequest) GetCid() []byte

func (*DHTRequest) GetCount 

func (m *DHTRequest) GetCount() int32

func (*DHTRequest) GetKey 

func (m *DHTRequest) GetKey() []byte

func (*DHTRequest) GetPeer 

func (m *DHTRequest) GetPeer() []byte

func (*DHTRequest) GetTimeout 

func (m *DHTRequest) GetTimeout() int64

func (*DHTRequest) GetType 

func (m *DHTRequest) GetType() DHTRequest_Type

func (*DHTRequest) GetValue 

func (m *DHTRequest) GetValue() []byte

func (*DHTRequest) Marshal 

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

func (*DHTRequest) MarshalTo 

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

func (*DHTRequest) MarshalToSizedBuffer added in v0.2.3 

func (m *DHTRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DHTRequest) ProtoMessage 

func (*DHTRequest) ProtoMessage()

func (*DHTRequest) Reset 

func (m *DHTRequest) Reset()

func (*DHTRequest) Size 

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

func (*DHTRequest) String 

func (m *DHTRequest) String() string

func (*DHTRequest) Unmarshal 

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

func (*DHTRequest) XXX_DiscardUnknown 

func (m *DHTRequest) XXX_DiscardUnknown()

func (*DHTRequest) XXX_Marshal 

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

func (*DHTRequest) XXX_Merge 

func (m *DHTRequest) XXX_Merge(src proto.Message)

func (*DHTRequest) XXX_Size 

func (m *DHTRequest) XXX_Size() int

func (*DHTRequest) XXX_Unmarshal 

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

type DHTRequest_Type 

type DHTRequest_Type int32
const (
	DHTRequest_FIND_PEER                    DHTRequest_Type = 0
	DHTRequest_FIND_PEERS_CONNECTED_TO_PEER DHTRequest_Type = 1
	DHTRequest_FIND_PROVIDERS               DHTRequest_Type = 2
	DHTRequest_GET_CLOSEST_PEERS            DHTRequest_Type = 3
	DHTRequest_GET_PUBLIC_KEY               DHTRequest_Type = 4
	DHTRequest_GET_VALUE                    DHTRequest_Type = 5
	DHTRequest_SEARCH_VALUE                 DHTRequest_Type = 6
	DHTRequest_PUT_VALUE                    DHTRequest_Type = 7
	DHTRequest_PROVIDE                      DHTRequest_Type = 8
)

func (DHTRequest_Type) Enum 

func (x DHTRequest_Type) Enum() *DHTRequest_Type

func (DHTRequest_Type) EnumDescriptor 

func (DHTRequest_Type) EnumDescriptor() ([]byte, []int)

func (DHTRequest_Type) String 

func (x DHTRequest_Type) String() string

func (*DHTRequest_Type) UnmarshalJSON 

func (x *DHTRequest_Type) UnmarshalJSON(data []byte) error

type DHTResponse 

type DHTResponse struct {
	Type                 *DHTResponse_Type `protobuf:"varint,1,req,name=type,enum=p2pd.pb.DHTResponse_Type" json:"type,omitempty"`
	Peer                 *PeerInfo         `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"`
	Value                []byte            `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DHTResponse) Descriptor 

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

func (*DHTResponse) GetPeer 

func (m *DHTResponse) GetPeer() *PeerInfo

func (*DHTResponse) GetType 

func (m *DHTResponse) GetType() DHTResponse_Type

func (*DHTResponse) GetValue 

func (m *DHTResponse) GetValue() []byte

func (*DHTResponse) Marshal 

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

func (*DHTResponse) MarshalTo 

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

func (*DHTResponse) MarshalToSizedBuffer added in v0.2.3 

func (m *DHTResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DHTResponse) ProtoMessage 

func (*DHTResponse) ProtoMessage()

func (*DHTResponse) Reset 

func (m *DHTResponse) Reset()

func (*DHTResponse) Size 

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

func (*DHTResponse) String 

func (m *DHTResponse) String() string

func (*DHTResponse) Unmarshal 

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

func (*DHTResponse) XXX_DiscardUnknown 

func (m *DHTResponse) XXX_DiscardUnknown()

func (*DHTResponse) XXX_Marshal 

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

func (*DHTResponse) XXX_Merge 

func (m *DHTResponse) XXX_Merge(src proto.Message)

func (*DHTResponse) XXX_Size 

func (m *DHTResponse) XXX_Size() int

func (*DHTResponse) XXX_Unmarshal 

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

type DHTResponse_Type 

type DHTResponse_Type int32
const (
	DHTResponse_BEGIN DHTResponse_Type = 0
	DHTResponse_VALUE DHTResponse_Type = 1
	DHTResponse_END   DHTResponse_Type = 2
)

func (DHTResponse_Type) Enum 

func (x DHTResponse_Type) Enum() *DHTResponse_Type

func (DHTResponse_Type) EnumDescriptor 

func (DHTResponse_Type) EnumDescriptor() ([]byte, []int)

func (DHTResponse_Type) String 

func (x DHTResponse_Type) String() string

func (*DHTResponse_Type) UnmarshalJSON 

func (x *DHTResponse_Type) UnmarshalJSON(data []byte) error

type DisconnectRequest 

type DisconnectRequest struct {
	Peer                 []byte   `protobuf:"bytes,1,req,name=peer" json:"peer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DisconnectRequest) Descriptor 

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

func (*DisconnectRequest) GetPeer 

func (m *DisconnectRequest) GetPeer() []byte

func (*DisconnectRequest) Marshal 

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

func (*DisconnectRequest) MarshalTo 

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

func (*DisconnectRequest) MarshalToSizedBuffer added in v0.2.3 

func (m *DisconnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DisconnectRequest) ProtoMessage 

func (*DisconnectRequest) ProtoMessage()

func (*DisconnectRequest) Reset 

func (m *DisconnectRequest) Reset()

func (*DisconnectRequest) Size 

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

func (*DisconnectRequest) String 

func (m *DisconnectRequest) String() string

func (*DisconnectRequest) Unmarshal 

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

func (*DisconnectRequest) XXX_DiscardUnknown 

func (m *DisconnectRequest) XXX_DiscardUnknown()

func (*DisconnectRequest) XXX_Marshal 

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

func (*DisconnectRequest) XXX_Merge 

func (m *DisconnectRequest) XXX_Merge(src proto.Message)

func (*DisconnectRequest) XXX_Size 

func (m *DisconnectRequest) XXX_Size() int

func (*DisconnectRequest) XXX_Unmarshal 

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

type ErrorResponse 

type ErrorResponse struct {
	Msg                  *string  `protobuf:"bytes,1,req,name=msg" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrorResponse) Descriptor 

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

func (*ErrorResponse) GetMsg 

func (m *ErrorResponse) GetMsg() string

func (*ErrorResponse) Marshal 

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

func (*ErrorResponse) MarshalTo 

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

func (*ErrorResponse) MarshalToSizedBuffer added in v0.2.3 

func (m *ErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) Reset 

func (m *ErrorResponse) Reset()

func (*ErrorResponse) Size 

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

func (*ErrorResponse) String 

func (m *ErrorResponse) String() string

func (*ErrorResponse) Unmarshal 

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

func (*ErrorResponse) XXX_DiscardUnknown 

func (m *ErrorResponse) XXX_DiscardUnknown()

func (*ErrorResponse) XXX_Marshal 

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

func (*ErrorResponse) XXX_Merge 

func (m *ErrorResponse) XXX_Merge(src proto.Message)

func (*ErrorResponse) XXX_Size 

func (m *ErrorResponse) XXX_Size() int

func (*ErrorResponse) XXX_Unmarshal 

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

type IdentifyResponse 

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

func (*IdentifyResponse) Descriptor 

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

func (*IdentifyResponse) GetAddrs 

func (m *IdentifyResponse) GetAddrs() [][]byte

func (*IdentifyResponse) GetId 

func (m *IdentifyResponse) GetId() []byte

func (*IdentifyResponse) Marshal 

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

func (*IdentifyResponse) MarshalTo 

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

func (*IdentifyResponse) MarshalToSizedBuffer added in v0.2.3 

func (m *IdentifyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*IdentifyResponse) ProtoMessage 

func (*IdentifyResponse) ProtoMessage()

func (*IdentifyResponse) Reset 

func (m *IdentifyResponse) Reset()

func (*IdentifyResponse) Size 

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

func (*IdentifyResponse) String 

func (m *IdentifyResponse) String() string

func (*IdentifyResponse) Unmarshal 

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

func (*IdentifyResponse) XXX_DiscardUnknown 

func (m *IdentifyResponse) XXX_DiscardUnknown()

func (*IdentifyResponse) XXX_Marshal 

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

func (*IdentifyResponse) XXX_Merge 

func (m *IdentifyResponse) XXX_Merge(src proto.Message)

func (*IdentifyResponse) XXX_Size 

func (m *IdentifyResponse) XXX_Size() int

func (*IdentifyResponse) XXX_Unmarshal 

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

type PSMessage 

type PSMessage struct {
	From                 []byte   `protobuf:"bytes,1,opt,name=from" json:"from,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	Seqno                []byte   `protobuf:"bytes,3,opt,name=seqno" json:"seqno,omitempty"`
	TopicIDs             []string `protobuf:"bytes,4,rep,name=topicIDs" json:"topicIDs,omitempty"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=signature" json:"signature,omitempty"`
	Key                  []byte   `protobuf:"bytes,6,opt,name=key" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PSMessage) Descriptor 

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

func (*PSMessage) GetData 

func (m *PSMessage) GetData() []byte

func (*PSMessage) GetFrom 

func (m *PSMessage) GetFrom() []byte

func (*PSMessage) GetKey 

func (m *PSMessage) GetKey() []byte

func (*PSMessage) GetSeqno 

func (m *PSMessage) GetSeqno() []byte

func (*PSMessage) GetSignature 

func (m *PSMessage) GetSignature() []byte

func (*PSMessage) GetTopicIDs 

func (m *PSMessage) GetTopicIDs() []string

func (*PSMessage) Marshal 

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

func (*PSMessage) MarshalTo 

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

func (*PSMessage) MarshalToSizedBuffer added in v0.2.3 

func (m *PSMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PSMessage) ProtoMessage 

func (*PSMessage) ProtoMessage()

func (*PSMessage) Reset 

func (m *PSMessage) Reset()

func (*PSMessage) Size 

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

func (*PSMessage) String 

func (m *PSMessage) String() string

func (*PSMessage) Unmarshal 

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

func (*PSMessage) XXX_DiscardUnknown 

func (m *PSMessage) XXX_DiscardUnknown()

func (*PSMessage) XXX_Marshal 

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

func (*PSMessage) XXX_Merge 

func (m *PSMessage) XXX_Merge(src proto.Message)

func (*PSMessage) XXX_Size 

func (m *PSMessage) XXX_Size() int

func (*PSMessage) XXX_Unmarshal 

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

type PSRequest 

type PSRequest struct {
	Type                 *PSRequest_Type `protobuf:"varint,1,req,name=type,enum=p2pd.pb.PSRequest_Type" json:"type,omitempty"`
	Topic                *string         `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
	Data                 []byte          `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PSRequest) Descriptor 

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

func (*PSRequest) GetData 

func (m *PSRequest) GetData() []byte

func (*PSRequest) GetTopic 

func (m *PSRequest) GetTopic() string

func (*PSRequest) GetType 

func (m *PSRequest) GetType() PSRequest_Type

func (*PSRequest) Marshal 

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

func (*PSRequest) MarshalTo 

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

func (*PSRequest) MarshalToSizedBuffer added in v0.2.3 

func (m *PSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PSRequest) ProtoMessage 

func (*PSRequest) ProtoMessage()

func (*PSRequest) Reset 

func (m *PSRequest) Reset()

func (*PSRequest) Size 

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

func (*PSRequest) String 

func (m *PSRequest) String() string

func (*PSRequest) Unmarshal 

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

func (*PSRequest) XXX_DiscardUnknown 

func (m *PSRequest) XXX_DiscardUnknown()

func (*PSRequest) XXX_Marshal 

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

func (*PSRequest) XXX_Merge 

func (m *PSRequest) XXX_Merge(src proto.Message)

func (*PSRequest) XXX_Size 

func (m *PSRequest) XXX_Size() int

func (*PSRequest) XXX_Unmarshal 

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

type PSRequest_Type 

type PSRequest_Type int32
const (
	PSRequest_GET_TOPICS PSRequest_Type = 0
	PSRequest_LIST_PEERS PSRequest_Type = 1
	PSRequest_PUBLISH    PSRequest_Type = 2
	PSRequest_SUBSCRIBE  PSRequest_Type = 3
)

func (PSRequest_Type) Enum 

func (x PSRequest_Type) Enum() *PSRequest_Type

func (PSRequest_Type) EnumDescriptor 

func (PSRequest_Type) EnumDescriptor() ([]byte, []int)

func (PSRequest_Type) String 

func (x PSRequest_Type) String() string

func (*PSRequest_Type) UnmarshalJSON 

func (x *PSRequest_Type) UnmarshalJSON(data []byte) error

type PSResponse 

type PSResponse struct {
	Topics               []string `protobuf:"bytes,1,rep,name=topics" json:"topics,omitempty"`
	PeerIDs              [][]byte `protobuf:"bytes,2,rep,name=peerIDs" json:"peerIDs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PSResponse) Descriptor 

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

func (*PSResponse) GetPeerIDs 

func (m *PSResponse) GetPeerIDs() [][]byte

func (*PSResponse) GetTopics 

func (m *PSResponse) GetTopics() []string

func (*PSResponse) Marshal 

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

func (*PSResponse) MarshalTo 

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

func (*PSResponse) MarshalToSizedBuffer added in v0.2.3 

func (m *PSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PSResponse) ProtoMessage 

func (*PSResponse) ProtoMessage()

func (*PSResponse) Reset 

func (m *PSResponse) Reset()

func (*PSResponse) Size 

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

func (*PSResponse) String 

func (m *PSResponse) String() string

func (*PSResponse) Unmarshal 

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

func (*PSResponse) XXX_DiscardUnknown 

func (m *PSResponse) XXX_DiscardUnknown()

func (*PSResponse) XXX_Marshal 

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

func (*PSResponse) XXX_Merge 

func (m *PSResponse) XXX_Merge(src proto.Message)

func (*PSResponse) XXX_Size 

func (m *PSResponse) XXX_Size() int

func (*PSResponse) XXX_Unmarshal 

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

type PeerInfo 

type PeerInfo struct {
	Id                   []byte   `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Addrs                [][]byte `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() [][]byte

func (*PeerInfo) GetId 

func (m *PeerInfo) GetId() []byte

func (*PeerInfo) Marshal 

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

func (*PeerInfo) MarshalTo 

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

func (*PeerInfo) MarshalToSizedBuffer added in v0.2.3 

func (m *PeerInfo) MarshalToSizedBuffer(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 (m *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 Request 

type Request struct {
	Type                 *Request_Type         `protobuf:"varint,1,req,name=type,enum=p2pd.pb.Request_Type" json:"type,omitempty"`
	Connect              *ConnectRequest       `protobuf:"bytes,2,opt,name=connect" json:"connect,omitempty"`
	StreamOpen           *StreamOpenRequest    `protobuf:"bytes,3,opt,name=streamOpen" json:"streamOpen,omitempty"`
	StreamHandler        *StreamHandlerRequest `protobuf:"bytes,4,opt,name=streamHandler" json:"streamHandler,omitempty"`
	Dht                  *DHTRequest           `protobuf:"bytes,5,opt,name=dht" json:"dht,omitempty"`
	ConnManager          *ConnManagerRequest   `protobuf:"bytes,6,opt,name=connManager" json:"connManager,omitempty"`
	Disconnect           *DisconnectRequest    `protobuf:"bytes,7,opt,name=disconnect" json:"disconnect,omitempty"`
	Pubsub               *PSRequest            `protobuf:"bytes,8,opt,name=pubsub" json:"pubsub,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetConnManager 

func (m *Request) GetConnManager() *ConnManagerRequest

func (*Request) GetConnect 

func (m *Request) GetConnect() *ConnectRequest

func (*Request) GetDht 

func (m *Request) GetDht() *DHTRequest

func (*Request) GetDisconnect 

func (m *Request) GetDisconnect() *DisconnectRequest

func (*Request) GetPubsub 

func (m *Request) GetPubsub() *PSRequest

func (*Request) GetStreamHandler 

func (m *Request) GetStreamHandler() *StreamHandlerRequest

func (*Request) GetStreamOpen 

func (m *Request) GetStreamOpen() *StreamOpenRequest

func (*Request) GetType 

func (m *Request) GetType() Request_Type

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer added in v0.2.3 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Request_Type 

type Request_Type int32
const (
	Request_IDENTIFY       Request_Type = 0
	Request_CONNECT        Request_Type = 1
	Request_STREAM_OPEN    Request_Type = 2
	Request_STREAM_HANDLER Request_Type = 3
	Request_DHT            Request_Type = 4
	Request_LIST_PEERS     Request_Type = 5
	Request_CONNMANAGER    Request_Type = 6
	Request_DISCONNECT     Request_Type = 7
	Request_PUBSUB         Request_Type = 8
)

func (Request_Type) Enum 

func (x Request_Type) Enum() *Request_Type

func (Request_Type) EnumDescriptor 

func (Request_Type) EnumDescriptor() ([]byte, []int)

func (Request_Type) String 

func (x Request_Type) String() string

func (*Request_Type) UnmarshalJSON 

func (x *Request_Type) UnmarshalJSON(data []byte) error

type Response 

type Response struct {
	Type                 *Response_Type    `protobuf:"varint,1,req,name=type,enum=p2pd.pb.Response_Type" json:"type,omitempty"`
	Error                *ErrorResponse    `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	StreamInfo           *StreamInfo       `protobuf:"bytes,3,opt,name=streamInfo" json:"streamInfo,omitempty"`
	Identify             *IdentifyResponse `protobuf:"bytes,4,opt,name=identify" json:"identify,omitempty"`
	Dht                  *DHTResponse      `protobuf:"bytes,5,opt,name=dht" json:"dht,omitempty"`
	Peers                []*PeerInfo       `protobuf:"bytes,6,rep,name=peers" json:"peers,omitempty"`
	Pubsub               *PSResponse       `protobuf:"bytes,7,opt,name=pubsub" json:"pubsub,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetDht 

func (m *Response) GetDht() *DHTResponse

func (*Response) GetError 

func (m *Response) GetError() *ErrorResponse

func (*Response) GetIdentify 

func (m *Response) GetIdentify() *IdentifyResponse

func (*Response) GetPeers 

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

func (*Response) GetPubsub 

func (m *Response) GetPubsub() *PSResponse

func (*Response) GetStreamInfo 

func (m *Response) GetStreamInfo() *StreamInfo

func (*Response) GetType 

func (m *Response) GetType() Response_Type

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer added in v0.2.3 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type Response_Type 

type Response_Type int32
const (
	Response_OK    Response_Type = 0
	Response_ERROR Response_Type = 1
)

func (Response_Type) Enum 

func (x Response_Type) Enum() *Response_Type

func (Response_Type) EnumDescriptor 

func (Response_Type) EnumDescriptor() ([]byte, []int)

func (Response_Type) String 

func (x Response_Type) String() string

func (*Response_Type) UnmarshalJSON 

func (x *Response_Type) UnmarshalJSON(data []byte) error

type StreamHandlerRequest 

type StreamHandlerRequest struct {
	Addr                 []byte   `protobuf:"bytes,1,req,name=addr" json:"addr,omitempty"`
	Proto                []string `protobuf:"bytes,2,rep,name=proto" json:"proto,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamHandlerRequest) Descriptor 

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

func (*StreamHandlerRequest) GetAddr 

func (m *StreamHandlerRequest) GetAddr() []byte

func (*StreamHandlerRequest) GetProto 

func (m *StreamHandlerRequest) GetProto() []string

func (*StreamHandlerRequest) Marshal 

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

func (*StreamHandlerRequest) MarshalTo 

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

func (*StreamHandlerRequest) MarshalToSizedBuffer added in v0.2.3 

func (m *StreamHandlerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamHandlerRequest) ProtoMessage 

func (*StreamHandlerRequest) ProtoMessage()

func (*StreamHandlerRequest) Reset 

func (m *StreamHandlerRequest) Reset()

func (*StreamHandlerRequest) Size 

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

func (*StreamHandlerRequest) String 

func (m *StreamHandlerRequest) String() string

func (*StreamHandlerRequest) Unmarshal 

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

func (*StreamHandlerRequest) XXX_DiscardUnknown 

func (m *StreamHandlerRequest) XXX_DiscardUnknown()

func (*StreamHandlerRequest) XXX_Marshal 

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

func (*StreamHandlerRequest) XXX_Merge 

func (m *StreamHandlerRequest) XXX_Merge(src proto.Message)

func (*StreamHandlerRequest) XXX_Size 

func (m *StreamHandlerRequest) XXX_Size() int

func (*StreamHandlerRequest) XXX_Unmarshal 

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

type StreamInfo 

type StreamInfo struct {
	Peer                 []byte   `protobuf:"bytes,1,req,name=peer" json:"peer,omitempty"`
	Addr                 []byte   `protobuf:"bytes,2,req,name=addr" json:"addr,omitempty"`
	Proto                *string  `protobuf:"bytes,3,req,name=proto" json:"proto,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamInfo) Descriptor 

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

func (*StreamInfo) GetAddr 

func (m *StreamInfo) GetAddr() []byte

func (*StreamInfo) GetPeer 

func (m *StreamInfo) GetPeer() []byte

func (*StreamInfo) GetProto 

func (m *StreamInfo) GetProto() string

func (*StreamInfo) Marshal 

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

func (*StreamInfo) MarshalTo 

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

func (*StreamInfo) MarshalToSizedBuffer added in v0.2.3 

func (m *StreamInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamInfo) ProtoMessage 

func (*StreamInfo) ProtoMessage()

func (*StreamInfo) Reset 

func (m *StreamInfo) Reset()

func (*StreamInfo) Size 

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

func (*StreamInfo) String 

func (m *StreamInfo) String() string

func (*StreamInfo) Unmarshal 

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

func (*StreamInfo) XXX_DiscardUnknown 

func (m *StreamInfo) XXX_DiscardUnknown()

func (*StreamInfo) XXX_Marshal 

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

func (*StreamInfo) XXX_Merge 

func (m *StreamInfo) XXX_Merge(src proto.Message)

func (*StreamInfo) XXX_Size 

func (m *StreamInfo) XXX_Size() int

func (*StreamInfo) XXX_Unmarshal 

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

type StreamOpenRequest 

type StreamOpenRequest struct {
	Peer                 []byte   `protobuf:"bytes,1,req,name=peer" json:"peer,omitempty"`
	Proto                []string `protobuf:"bytes,2,rep,name=proto" json:"proto,omitempty"`
	Timeout              *int64   `protobuf:"varint,3,opt,name=timeout" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamOpenRequest) Descriptor 

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

func (*StreamOpenRequest) GetPeer 

func (m *StreamOpenRequest) GetPeer() []byte

func (*StreamOpenRequest) GetProto 

func (m *StreamOpenRequest) GetProto() []string

func (*StreamOpenRequest) GetTimeout 

func (m *StreamOpenRequest) GetTimeout() int64

func (*StreamOpenRequest) Marshal 

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

func (*StreamOpenRequest) MarshalTo 

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

func (*StreamOpenRequest) MarshalToSizedBuffer added in v0.2.3 

func (m *StreamOpenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamOpenRequest) ProtoMessage 

func (*StreamOpenRequest) ProtoMessage()

func (*StreamOpenRequest) Reset 

func (m *StreamOpenRequest) Reset()

func (*StreamOpenRequest) Size 

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

func (*StreamOpenRequest) String 

func (m *StreamOpenRequest) String() string

func (*StreamOpenRequest) Unmarshal 

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

func (*StreamOpenRequest) XXX_DiscardUnknown 

func (m *StreamOpenRequest) XXX_DiscardUnknown()

func (*StreamOpenRequest) XXX_Marshal 

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

func (*StreamOpenRequest) XXX_Merge 

func (m *StreamOpenRequest) XXX_Merge(src proto.Message)

func (*StreamOpenRequest) XXX_Size 

func (m *StreamOpenRequest) XXX_Size() int

func (*StreamOpenRequest) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.