p2pd_pb

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2023 License: Apache-2.0, MIT Imports: 5 Imported by: 0

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",
	10: "REMOVE_STREAM_HANDLER",
	4:  "DHT",
	5:  "LIST_PEERS",
	6:  "CONNMANAGER",
	7:  "DISCONNECT",
	8:  "PUBSUB",
	9:  "PERSISTENT_CONN_UPGRADE",
}
View Source 
var Request_Type_value = map[string]int32{
	"IDENTIFY":                0,
	"CONNECT":                 1,
	"STREAM_OPEN":             2,
	"STREAM_HANDLER":          3,
	"REMOVE_STREAM_HANDLER":   10,
	"DHT":                     4,
	"LIST_PEERS":              5,
	"CONNMANAGER":             6,
	"DISCONNECT":              7,
	"PUBSUB":                  8,
	"PERSISTENT_CONN_UPGRADE": 9,
}
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 AddUnaryHandlerRequest 

type AddUnaryHandlerRequest struct {
	Proto                *string  `protobuf:"bytes,1,req,name=proto" json:"proto,omitempty"`
	Balanced             *bool    `protobuf:"varint,2,req,name=balanced" json:"balanced,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddUnaryHandlerRequest) Descriptor 

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

func (*AddUnaryHandlerRequest) GetBalanced 

func (m *AddUnaryHandlerRequest) GetBalanced() bool

func (*AddUnaryHandlerRequest) GetProto 

func (m *AddUnaryHandlerRequest) GetProto() string

func (*AddUnaryHandlerRequest) Marshal 

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

func (*AddUnaryHandlerRequest) MarshalTo 

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

func (*AddUnaryHandlerRequest) MarshalToSizedBuffer 

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

func (*AddUnaryHandlerRequest) ProtoMessage 

func (*AddUnaryHandlerRequest) ProtoMessage()

func (*AddUnaryHandlerRequest) Reset 

func (m *AddUnaryHandlerRequest) Reset()

func (*AddUnaryHandlerRequest) Size 

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

func (*AddUnaryHandlerRequest) String 

func (m *AddUnaryHandlerRequest) String() string

func (*AddUnaryHandlerRequest) Unmarshal 

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

func (*AddUnaryHandlerRequest) XXX_DiscardUnknown 

func (m *AddUnaryHandlerRequest) XXX_DiscardUnknown()

func (*AddUnaryHandlerRequest) XXX_Marshal 

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

func (*AddUnaryHandlerRequest) XXX_Merge 

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

func (*AddUnaryHandlerRequest) XXX_Size 

func (m *AddUnaryHandlerRequest) XXX_Size() int

func (*AddUnaryHandlerRequest) XXX_Unmarshal 

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

type CallUnaryRequest 

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

func (*CallUnaryRequest) Descriptor 

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

func (*CallUnaryRequest) GetData 

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

func (*CallUnaryRequest) GetPeer 

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

func (*CallUnaryRequest) GetProto 

func (m *CallUnaryRequest) GetProto() string

func (*CallUnaryRequest) Marshal 

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

func (*CallUnaryRequest) MarshalTo 

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

func (*CallUnaryRequest) MarshalToSizedBuffer 

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

func (*CallUnaryRequest) ProtoMessage 

func (*CallUnaryRequest) ProtoMessage()

func (*CallUnaryRequest) Reset 

func (m *CallUnaryRequest) Reset()

func (*CallUnaryRequest) Size 

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

func (*CallUnaryRequest) String 

func (m *CallUnaryRequest) String() string

func (*CallUnaryRequest) Unmarshal 

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

func (*CallUnaryRequest) XXX_DiscardUnknown 

func (m *CallUnaryRequest) XXX_DiscardUnknown()

func (*CallUnaryRequest) XXX_Marshal 

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

func (*CallUnaryRequest) XXX_Merge 

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

func (*CallUnaryRequest) XXX_Size 

func (m *CallUnaryRequest) XXX_Size() int

func (*CallUnaryRequest) XXX_Unmarshal 

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

type CallUnaryResponse 

type CallUnaryResponse struct {
	// Types that are valid to be assigned to Result:
	//	*CallUnaryResponse_Response
	//	*CallUnaryResponse_Error
	Result               isCallUnaryResponse_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*CallUnaryResponse) Descriptor 

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

func (*CallUnaryResponse) GetError 

func (m *CallUnaryResponse) GetError() []byte

func (*CallUnaryResponse) GetResponse 

func (m *CallUnaryResponse) GetResponse() []byte

func (*CallUnaryResponse) GetResult 

func (m *CallUnaryResponse) GetResult() isCallUnaryResponse_Result

func (*CallUnaryResponse) Marshal 

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

func (*CallUnaryResponse) MarshalTo 

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

func (*CallUnaryResponse) MarshalToSizedBuffer 

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

func (*CallUnaryResponse) ProtoMessage 

func (*CallUnaryResponse) ProtoMessage()

func (*CallUnaryResponse) Reset 

func (m *CallUnaryResponse) Reset()

func (*CallUnaryResponse) Size 

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

func (*CallUnaryResponse) String 

func (m *CallUnaryResponse) String() string

func (*CallUnaryResponse) Unmarshal 

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

func (*CallUnaryResponse) XXX_DiscardUnknown 

func (m *CallUnaryResponse) XXX_DiscardUnknown()

func (*CallUnaryResponse) XXX_Marshal 

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

func (*CallUnaryResponse) XXX_Merge 

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

func (*CallUnaryResponse) XXX_OneofWrappers 

func (*CallUnaryResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CallUnaryResponse) XXX_Size 

func (m *CallUnaryResponse) XXX_Size() int

func (*CallUnaryResponse) XXX_Unmarshal 

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

type CallUnaryResponse_Error 

type CallUnaryResponse_Error struct {
	Error []byte `protobuf:"bytes,2,opt,name=error,oneof" json:"error,omitempty"`
}

func (*CallUnaryResponse_Error) MarshalTo 

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

func (*CallUnaryResponse_Error) MarshalToSizedBuffer 

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

func (*CallUnaryResponse_Error) Size 

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

type CallUnaryResponse_Response 

type CallUnaryResponse_Response struct {
	Response []byte `protobuf:"bytes,1,opt,name=response,oneof" json:"response,omitempty"`
}

func (*CallUnaryResponse_Response) MarshalTo 

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

func (*CallUnaryResponse_Response) MarshalToSizedBuffer 

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

func (*CallUnaryResponse_Response) Size 

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

type Cancel 

type Cancel struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Cancel) Descriptor 

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

func (*Cancel) Marshal 

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

func (*Cancel) MarshalTo 

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

func (*Cancel) MarshalToSizedBuffer 

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

func (*Cancel) ProtoMessage 

func (*Cancel) ProtoMessage()

func (*Cancel) Reset 

func (m *Cancel) Reset()

func (*Cancel) Size 

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

func (*Cancel) String 

func (m *Cancel) String() string

func (*Cancel) Unmarshal 

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

func (*Cancel) XXX_DiscardUnknown 

func (m *Cancel) XXX_DiscardUnknown()

func (*Cancel) XXX_Marshal 

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

func (*Cancel) XXX_Merge 

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

func (*Cancel) XXX_Size 

func (m *Cancel) XXX_Size() int

func (*Cancel) XXX_Unmarshal 

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

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 

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 

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 

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 

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 DaemonError 

type DaemonError struct {
	Message              *string  `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DaemonError) Descriptor 

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

func (*DaemonError) GetMessage 

func (m *DaemonError) GetMessage() string

func (*DaemonError) Marshal 

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

func (*DaemonError) MarshalTo 

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

func (*DaemonError) MarshalToSizedBuffer 

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

func (*DaemonError) ProtoMessage 

func (*DaemonError) ProtoMessage()

func (*DaemonError) Reset 

func (m *DaemonError) Reset()

func (*DaemonError) Size 

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

func (*DaemonError) String 

func (m *DaemonError) String() string

func (*DaemonError) Unmarshal 

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

func (*DaemonError) XXX_DiscardUnknown 

func (m *DaemonError) XXX_DiscardUnknown()

func (*DaemonError) XXX_Marshal 

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

func (*DaemonError) XXX_Merge 

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

func (*DaemonError) XXX_Size 

func (m *DaemonError) XXX_Size() int

func (*DaemonError) XXX_Unmarshal 

func (m *DaemonError) XXX_Unmarshal(b []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 

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 

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 

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 

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 

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 

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 

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 PersistentConnectionRequest 

type PersistentConnectionRequest struct {
	CallId []byte `protobuf:"bytes,1,req,name=callId" json:"callId,omitempty"`
	// Types that are valid to be assigned to Message:
	//	*PersistentConnectionRequest_AddUnaryHandler
	//	*PersistentConnectionRequest_RemoveUnaryHandler
	//	*PersistentConnectionRequest_CallUnary
	//	*PersistentConnectionRequest_UnaryResponse
	//	*PersistentConnectionRequest_Cancel
	Message              isPersistentConnectionRequest_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*PersistentConnectionRequest) Descriptor 

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

func (*PersistentConnectionRequest) GetAddUnaryHandler 

func (m *PersistentConnectionRequest) GetAddUnaryHandler() *AddUnaryHandlerRequest

func (*PersistentConnectionRequest) GetCallId 

func (m *PersistentConnectionRequest) GetCallId() []byte

func (*PersistentConnectionRequest) GetCallUnary 

func (m *PersistentConnectionRequest) GetCallUnary() *CallUnaryRequest

func (*PersistentConnectionRequest) GetCancel 

func (m *PersistentConnectionRequest) GetCancel() *Cancel

func (*PersistentConnectionRequest) GetMessage 

func (m *PersistentConnectionRequest) GetMessage() isPersistentConnectionRequest_Message

func (*PersistentConnectionRequest) GetRemoveUnaryHandler 

func (m *PersistentConnectionRequest) GetRemoveUnaryHandler() *RemoveUnaryHandlerRequest

func (*PersistentConnectionRequest) GetUnaryResponse 

func (m *PersistentConnectionRequest) GetUnaryResponse() *CallUnaryResponse

func (*PersistentConnectionRequest) Marshal 

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

func (*PersistentConnectionRequest) MarshalTo 

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

func (*PersistentConnectionRequest) MarshalToSizedBuffer 

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

func (*PersistentConnectionRequest) ProtoMessage 

func (*PersistentConnectionRequest) ProtoMessage()

func (*PersistentConnectionRequest) Reset 

func (m *PersistentConnectionRequest) Reset()

func (*PersistentConnectionRequest) Size 

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

func (*PersistentConnectionRequest) String 

func (m *PersistentConnectionRequest) String() string

func (*PersistentConnectionRequest) Unmarshal 

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

func (*PersistentConnectionRequest) XXX_DiscardUnknown 

func (m *PersistentConnectionRequest) XXX_DiscardUnknown()

func (*PersistentConnectionRequest) XXX_Marshal 

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

func (*PersistentConnectionRequest) XXX_Merge 

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

func (*PersistentConnectionRequest) XXX_OneofWrappers 

func (*PersistentConnectionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PersistentConnectionRequest) XXX_Size 

func (m *PersistentConnectionRequest) XXX_Size() int

func (*PersistentConnectionRequest) XXX_Unmarshal 

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

type PersistentConnectionRequest_AddUnaryHandler 

type PersistentConnectionRequest_AddUnaryHandler struct {
	AddUnaryHandler *AddUnaryHandlerRequest `protobuf:"bytes,2,opt,name=addUnaryHandler,oneof" json:"addUnaryHandler,omitempty"`
}

func (*PersistentConnectionRequest_AddUnaryHandler) MarshalTo 

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

func (*PersistentConnectionRequest_AddUnaryHandler) MarshalToSizedBuffer 

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

func (*PersistentConnectionRequest_AddUnaryHandler) Size 

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

type PersistentConnectionRequest_CallUnary 

type PersistentConnectionRequest_CallUnary struct {
	CallUnary *CallUnaryRequest `protobuf:"bytes,3,opt,name=callUnary,oneof" json:"callUnary,omitempty"`
}

func (*PersistentConnectionRequest_CallUnary) MarshalTo 

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

func (*PersistentConnectionRequest_CallUnary) MarshalToSizedBuffer 

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

func (*PersistentConnectionRequest_CallUnary) Size 

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

type PersistentConnectionRequest_Cancel 

type PersistentConnectionRequest_Cancel struct {
	Cancel *Cancel `protobuf:"bytes,5,opt,name=cancel,oneof" json:"cancel,omitempty"`
}

func (*PersistentConnectionRequest_Cancel) MarshalTo 

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

func (*PersistentConnectionRequest_Cancel) MarshalToSizedBuffer 

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

func (*PersistentConnectionRequest_Cancel) Size 

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

type PersistentConnectionRequest_RemoveUnaryHandler 

type PersistentConnectionRequest_RemoveUnaryHandler struct {
	RemoveUnaryHandler *RemoveUnaryHandlerRequest `protobuf:"bytes,6,opt,name=removeUnaryHandler,oneof" json:"removeUnaryHandler,omitempty"`
}

func (*PersistentConnectionRequest_RemoveUnaryHandler) MarshalTo 

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

func (*PersistentConnectionRequest_RemoveUnaryHandler) MarshalToSizedBuffer 

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

func (*PersistentConnectionRequest_RemoveUnaryHandler) Size 

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

type PersistentConnectionRequest_UnaryResponse 

type PersistentConnectionRequest_UnaryResponse struct {
	UnaryResponse *CallUnaryResponse `protobuf:"bytes,4,opt,name=unaryResponse,oneof" json:"unaryResponse,omitempty"`
}

func (*PersistentConnectionRequest_UnaryResponse) MarshalTo 

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

func (*PersistentConnectionRequest_UnaryResponse) MarshalToSizedBuffer 

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

func (*PersistentConnectionRequest_UnaryResponse) Size 

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

type PersistentConnectionResponse 

type PersistentConnectionResponse struct {
	CallId []byte `protobuf:"bytes,1,req,name=callId" json:"callId,omitempty"`
	// Types that are valid to be assigned to Message:
	//	*PersistentConnectionResponse_CallUnaryResponse
	//	*PersistentConnectionResponse_RequestHandling
	//	*PersistentConnectionResponse_DaemonError
	//	*PersistentConnectionResponse_Cancel
	Message              isPersistentConnectionResponse_Message `protobuf_oneof:"message"`
	XXX_NoUnkeyedLiteral struct{}                               `json:"-"`
	XXX_unrecognized     []byte                                 `json:"-"`
	XXX_sizecache        int32                                  `json:"-"`
}

func (*PersistentConnectionResponse) Descriptor 

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

func (*PersistentConnectionResponse) GetCallId 

func (m *PersistentConnectionResponse) GetCallId() []byte

func (*PersistentConnectionResponse) GetCallUnaryResponse 

func (m *PersistentConnectionResponse) GetCallUnaryResponse() *CallUnaryResponse

func (*PersistentConnectionResponse) GetCancel 

func (m *PersistentConnectionResponse) GetCancel() *Cancel

func (*PersistentConnectionResponse) GetDaemonError 

func (m *PersistentConnectionResponse) GetDaemonError() *DaemonError

func (*PersistentConnectionResponse) GetMessage 

func (m *PersistentConnectionResponse) GetMessage() isPersistentConnectionResponse_Message

func (*PersistentConnectionResponse) GetRequestHandling 

func (m *PersistentConnectionResponse) GetRequestHandling() *CallUnaryRequest

func (*PersistentConnectionResponse) Marshal 

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

func (*PersistentConnectionResponse) MarshalTo 

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

func (*PersistentConnectionResponse) MarshalToSizedBuffer 

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

func (*PersistentConnectionResponse) ProtoMessage 

func (*PersistentConnectionResponse) ProtoMessage()

func (*PersistentConnectionResponse) Reset 

func (m *PersistentConnectionResponse) Reset()

func (*PersistentConnectionResponse) Size 

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

func (*PersistentConnectionResponse) String 

func (m *PersistentConnectionResponse) String() string

func (*PersistentConnectionResponse) Unmarshal 

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

func (*PersistentConnectionResponse) XXX_DiscardUnknown 

func (m *PersistentConnectionResponse) XXX_DiscardUnknown()

func (*PersistentConnectionResponse) XXX_Marshal 

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

func (*PersistentConnectionResponse) XXX_Merge 

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

func (*PersistentConnectionResponse) XXX_OneofWrappers 

func (*PersistentConnectionResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PersistentConnectionResponse) XXX_Size 

func (m *PersistentConnectionResponse) XXX_Size() int

func (*PersistentConnectionResponse) XXX_Unmarshal 

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

type PersistentConnectionResponse_CallUnaryResponse 

type PersistentConnectionResponse_CallUnaryResponse struct {
	CallUnaryResponse *CallUnaryResponse `protobuf:"bytes,2,opt,name=callUnaryResponse,oneof" json:"callUnaryResponse,omitempty"`
}

func (*PersistentConnectionResponse_CallUnaryResponse) MarshalTo 

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

func (*PersistentConnectionResponse_CallUnaryResponse) MarshalToSizedBuffer 

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

func (*PersistentConnectionResponse_CallUnaryResponse) Size 

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

type PersistentConnectionResponse_Cancel 

type PersistentConnectionResponse_Cancel struct {
	Cancel *Cancel `protobuf:"bytes,5,opt,name=cancel,oneof" json:"cancel,omitempty"`
}

func (*PersistentConnectionResponse_Cancel) MarshalTo 

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

func (*PersistentConnectionResponse_Cancel) MarshalToSizedBuffer 

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

func (*PersistentConnectionResponse_Cancel) Size 

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

type PersistentConnectionResponse_DaemonError 

type PersistentConnectionResponse_DaemonError struct {
	DaemonError *DaemonError `protobuf:"bytes,4,opt,name=daemonError,oneof" json:"daemonError,omitempty"`
}

func (*PersistentConnectionResponse_DaemonError) MarshalTo 

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

func (*PersistentConnectionResponse_DaemonError) MarshalToSizedBuffer 

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

func (*PersistentConnectionResponse_DaemonError) Size 

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

type PersistentConnectionResponse_RequestHandling 

type PersistentConnectionResponse_RequestHandling struct {
	RequestHandling *CallUnaryRequest `protobuf:"bytes,3,opt,name=requestHandling,oneof" json:"requestHandling,omitempty"`
}

func (*PersistentConnectionResponse_RequestHandling) MarshalTo 

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

func (*PersistentConnectionResponse_RequestHandling) MarshalToSizedBuffer 

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

func (*PersistentConnectionResponse_RequestHandling) Size 

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

type RemoveStreamHandlerRequest 

type RemoveStreamHandlerRequest 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 (*RemoveStreamHandlerRequest) Descriptor 

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

func (*RemoveStreamHandlerRequest) GetAddr 

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

func (*RemoveStreamHandlerRequest) GetProto 

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

func (*RemoveStreamHandlerRequest) Marshal 

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

func (*RemoveStreamHandlerRequest) MarshalTo 

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

func (*RemoveStreamHandlerRequest) MarshalToSizedBuffer 

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

func (*RemoveStreamHandlerRequest) ProtoMessage 

func (*RemoveStreamHandlerRequest) ProtoMessage()

func (*RemoveStreamHandlerRequest) Reset 

func (m *RemoveStreamHandlerRequest) Reset()

func (*RemoveStreamHandlerRequest) Size 

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

func (*RemoveStreamHandlerRequest) String 

func (m *RemoveStreamHandlerRequest) String() string

func (*RemoveStreamHandlerRequest) Unmarshal 

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

func (*RemoveStreamHandlerRequest) XXX_DiscardUnknown 

func (m *RemoveStreamHandlerRequest) XXX_DiscardUnknown()

func (*RemoveStreamHandlerRequest) XXX_Marshal 

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

func (*RemoveStreamHandlerRequest) XXX_Merge 

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

func (*RemoveStreamHandlerRequest) XXX_Size 

func (m *RemoveStreamHandlerRequest) XXX_Size() int

func (*RemoveStreamHandlerRequest) XXX_Unmarshal 

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

type RemoveUnaryHandlerRequest 

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

func (*RemoveUnaryHandlerRequest) Descriptor 

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

func (*RemoveUnaryHandlerRequest) GetProto 

func (m *RemoveUnaryHandlerRequest) GetProto() string

func (*RemoveUnaryHandlerRequest) Marshal 

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

func (*RemoveUnaryHandlerRequest) MarshalTo 

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

func (*RemoveUnaryHandlerRequest) MarshalToSizedBuffer 

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

func (*RemoveUnaryHandlerRequest) ProtoMessage 

func (*RemoveUnaryHandlerRequest) ProtoMessage()

func (*RemoveUnaryHandlerRequest) Reset 

func (m *RemoveUnaryHandlerRequest) Reset()

func (*RemoveUnaryHandlerRequest) Size 

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

func (*RemoveUnaryHandlerRequest) String 

func (m *RemoveUnaryHandlerRequest) String() string

func (*RemoveUnaryHandlerRequest) Unmarshal 

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

func (*RemoveUnaryHandlerRequest) XXX_DiscardUnknown 

func (m *RemoveUnaryHandlerRequest) XXX_DiscardUnknown()

func (*RemoveUnaryHandlerRequest) XXX_Marshal 

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

func (*RemoveUnaryHandlerRequest) XXX_Merge 

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

func (*RemoveUnaryHandlerRequest) XXX_Size 

func (m *RemoveUnaryHandlerRequest) XXX_Size() int

func (*RemoveUnaryHandlerRequest) XXX_Unmarshal 

func (m *RemoveUnaryHandlerRequest) 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"`
	RemoveStreamHandler  *RemoveStreamHandlerRequest `protobuf:"bytes,9,opt,name=removeStreamHandler" json:"removeStreamHandler,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) GetRemoveStreamHandler 

func (m *Request) GetRemoveStreamHandler() *RemoveStreamHandlerRequest

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 

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_REMOVE_STREAM_HANDLER   Request_Type = 10
	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
	Request_PERSISTENT_CONN_UPGRADE Request_Type = 9
)

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 

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"`
	Balanced             *bool    `protobuf:"varint,3,req,name=balanced" json:"balanced,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) GetBalanced 

func (m *StreamHandlerRequest) GetBalanced() bool

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 

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 

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 

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.