Documentation
      ¶
    
    
  
    
  
    Index ¶
- func DRPCRegisterPeerService(mux drpc.Mux, impl DRPCPeerServiceServer) error
 - func RegisterPeerServiceServer(s *grpc.Server, srv PeerServiceServer)
 - type DRPCPeerServiceClient
 - type DRPCPeerServiceDescription
 - type DRPCPeerServiceServer
 - type DRPCPeerServiceUnimplementedServer
 - type DRPCPeerService_GetPeerInfoStream
 - type DRPCPeerService_IdentifyClient
 - type DRPCPeerService_IdentifyStream
 - type GetPeerInfoRequest
 - func (*GetPeerInfoRequest) Descriptor() ([]byte, []int)
 - func (m *GetPeerInfoRequest) GetPeerId() string
 - func (*GetPeerInfoRequest) ProtoMessage()
 - func (m *GetPeerInfoRequest) Reset()
 - func (m *GetPeerInfoRequest) String() string
 - func (m *GetPeerInfoRequest) XXX_DiscardUnknown()
 - func (m *GetPeerInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *GetPeerInfoRequest) XXX_Merge(src proto.Message)
 - func (m *GetPeerInfoRequest) XXX_Size() int
 - func (m *GetPeerInfoRequest) XXX_Unmarshal(b []byte) error
 
- type GetPeerInfoResponse
 - func (*GetPeerInfoResponse) Descriptor() ([]byte, []int)
 - func (m *GetPeerInfoResponse) GetLocalPeers() []*PeerInfo
 - func (*GetPeerInfoResponse) ProtoMessage()
 - func (m *GetPeerInfoResponse) Reset()
 - func (m *GetPeerInfoResponse) String() string
 - func (m *GetPeerInfoResponse) XXX_DiscardUnknown()
 - func (m *GetPeerInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *GetPeerInfoResponse) XXX_Merge(src proto.Message)
 - func (m *GetPeerInfoResponse) XXX_Size() int
 - func (m *GetPeerInfoResponse) XXX_Unmarshal(b []byte) error
 
- type IdentifyRequest
 - func (*IdentifyRequest) Descriptor() ([]byte, []int)
 - func (m *IdentifyRequest) GetConfig() *controller.Config
 - func (*IdentifyRequest) ProtoMessage()
 - func (m *IdentifyRequest) Reset()
 - func (m *IdentifyRequest) String() string
 - func (m *IdentifyRequest) XXX_DiscardUnknown()
 - func (m *IdentifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *IdentifyRequest) XXX_Merge(src proto.Message)
 - func (m *IdentifyRequest) XXX_Size() int
 - func (m *IdentifyRequest) XXX_Unmarshal(b []byte) error
 
- type IdentifyResponse
 - func (*IdentifyResponse) Descriptor() ([]byte, []int)
 - func (m *IdentifyResponse) GetControllerStatus() exec.ControllerStatus
 - func (*IdentifyResponse) ProtoMessage()
 - func (m *IdentifyResponse) Reset()
 - func (m *IdentifyResponse) String() string
 - func (m *IdentifyResponse) XXX_DiscardUnknown()
 - func (m *IdentifyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *IdentifyResponse) XXX_Merge(src proto.Message)
 - func (m *IdentifyResponse) XXX_Size() int
 - func (m *IdentifyResponse) XXX_Unmarshal(b []byte) error
 
- type PeerInfo
 - func (*PeerInfo) Descriptor() ([]byte, []int)
 - func (m *PeerInfo) GetPeerId() string
 - func (*PeerInfo) ProtoMessage()
 - func (m *PeerInfo) Reset()
 - func (m *PeerInfo) String() string
 - func (m *PeerInfo) XXX_DiscardUnknown()
 - func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
 - func (m *PeerInfo) XXX_Merge(src proto.Message)
 - func (m *PeerInfo) XXX_Size() int
 - func (m *PeerInfo) XXX_Unmarshal(b []byte) error
 
- type PeerServiceClient
 - type PeerServiceServer
 - type PeerService_IdentifyClient
 - type PeerService_IdentifyServer
 - type UnimplementedPeerServiceServer
 
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DRPCRegisterPeerService ¶
func DRPCRegisterPeerService(mux drpc.Mux, impl DRPCPeerServiceServer) error
func RegisterPeerServiceServer ¶
func RegisterPeerServiceServer(s *grpc.Server, srv PeerServiceServer)
Types ¶
type DRPCPeerServiceClient ¶
type DRPCPeerServiceClient interface {
	DRPCConn() drpc.Conn
	Identify(ctx context.Context, in *IdentifyRequest) (DRPCPeerService_IdentifyClient, error)
	GetPeerInfo(ctx context.Context, in *GetPeerInfoRequest) (*GetPeerInfoResponse, error)
}
    func NewDRPCPeerServiceClient ¶
func NewDRPCPeerServiceClient(cc drpc.Conn) DRPCPeerServiceClient
type DRPCPeerServiceDescription ¶
type DRPCPeerServiceDescription struct{}
    func (DRPCPeerServiceDescription) NumMethods ¶
func (DRPCPeerServiceDescription) NumMethods() int
type DRPCPeerServiceServer ¶
type DRPCPeerServiceServer interface {
	Identify(*IdentifyRequest, DRPCPeerService_IdentifyStream) error
	GetPeerInfo(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)
}
    type DRPCPeerServiceUnimplementedServer ¶
type DRPCPeerServiceUnimplementedServer struct{}
    func (*DRPCPeerServiceUnimplementedServer) GetPeerInfo ¶
func (s *DRPCPeerServiceUnimplementedServer) GetPeerInfo(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)
func (*DRPCPeerServiceUnimplementedServer) Identify ¶
func (s *DRPCPeerServiceUnimplementedServer) Identify(*IdentifyRequest, DRPCPeerService_IdentifyStream) error
type DRPCPeerService_GetPeerInfoStream ¶
type DRPCPeerService_GetPeerInfoStream interface {
	drpc.Stream
	SendAndClose(*GetPeerInfoResponse) error
}
    type DRPCPeerService_IdentifyClient ¶
type DRPCPeerService_IdentifyClient interface {
	drpc.Stream
	Recv() (*IdentifyResponse, error)
}
    type DRPCPeerService_IdentifyStream ¶
type DRPCPeerService_IdentifyStream interface {
	drpc.Stream
	Send(*IdentifyResponse) error
}
    type GetPeerInfoRequest ¶
type GetPeerInfoRequest struct {
	// PeerId restricts the response to a specific peer ID.
	PeerId               string   `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    GetPeerInfoRequest is the request type for GetPeerInfo.
func (*GetPeerInfoRequest) Descriptor ¶
func (*GetPeerInfoRequest) Descriptor() ([]byte, []int)
func (*GetPeerInfoRequest) GetPeerId ¶
func (m *GetPeerInfoRequest) GetPeerId() string
func (*GetPeerInfoRequest) ProtoMessage ¶
func (*GetPeerInfoRequest) ProtoMessage()
func (*GetPeerInfoRequest) Reset ¶
func (m *GetPeerInfoRequest) Reset()
func (*GetPeerInfoRequest) String ¶
func (m *GetPeerInfoRequest) String() string
func (*GetPeerInfoRequest) XXX_DiscardUnknown ¶
func (m *GetPeerInfoRequest) XXX_DiscardUnknown()
func (*GetPeerInfoRequest) XXX_Marshal ¶
func (m *GetPeerInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPeerInfoRequest) XXX_Merge ¶
func (m *GetPeerInfoRequest) XXX_Merge(src proto.Message)
func (*GetPeerInfoRequest) XXX_Size ¶
func (m *GetPeerInfoRequest) XXX_Size() int
func (*GetPeerInfoRequest) XXX_Unmarshal ¶
func (m *GetPeerInfoRequest) XXX_Unmarshal(b []byte) error
type GetPeerInfoResponse ¶
type GetPeerInfoResponse struct {
	// LocalPeers is the set of peers loaded.
	LocalPeers           []*PeerInfo `protobuf:"bytes,1,rep,name=local_peers,json=localPeers,proto3" json:"local_peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}
    GetPeerInfoResponse is the response type for GetPeerInfo.
func (*GetPeerInfoResponse) Descriptor ¶
func (*GetPeerInfoResponse) Descriptor() ([]byte, []int)
func (*GetPeerInfoResponse) GetLocalPeers ¶
func (m *GetPeerInfoResponse) GetLocalPeers() []*PeerInfo
func (*GetPeerInfoResponse) ProtoMessage ¶
func (*GetPeerInfoResponse) ProtoMessage()
func (*GetPeerInfoResponse) Reset ¶
func (m *GetPeerInfoResponse) Reset()
func (*GetPeerInfoResponse) String ¶
func (m *GetPeerInfoResponse) String() string
func (*GetPeerInfoResponse) XXX_DiscardUnknown ¶
func (m *GetPeerInfoResponse) XXX_DiscardUnknown()
func (*GetPeerInfoResponse) XXX_Marshal ¶
func (m *GetPeerInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetPeerInfoResponse) XXX_Merge ¶
func (m *GetPeerInfoResponse) XXX_Merge(src proto.Message)
func (*GetPeerInfoResponse) XXX_Size ¶
func (m *GetPeerInfoResponse) XXX_Size() int
func (*GetPeerInfoResponse) XXX_Unmarshal ¶
func (m *GetPeerInfoResponse) XXX_Unmarshal(b []byte) error
type IdentifyRequest ¶
type IdentifyRequest struct {
	// Config is the request to configure the peer controller.
	Config               *controller.Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}
    IdentifyRequest is a request to load an identity.
func (*IdentifyRequest) Descriptor ¶
func (*IdentifyRequest) Descriptor() ([]byte, []int)
func (*IdentifyRequest) GetConfig ¶
func (m *IdentifyRequest) GetConfig() *controller.Config
func (*IdentifyRequest) ProtoMessage ¶
func (*IdentifyRequest) ProtoMessage()
func (*IdentifyRequest) Reset ¶
func (m *IdentifyRequest) Reset()
func (*IdentifyRequest) String ¶
func (m *IdentifyRequest) String() string
func (*IdentifyRequest) XXX_DiscardUnknown ¶
func (m *IdentifyRequest) XXX_DiscardUnknown()
func (*IdentifyRequest) XXX_Marshal ¶
func (m *IdentifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IdentifyRequest) XXX_Merge ¶
func (m *IdentifyRequest) XXX_Merge(src proto.Message)
func (*IdentifyRequest) XXX_Size ¶
func (m *IdentifyRequest) XXX_Size() int
func (*IdentifyRequest) XXX_Unmarshal ¶
func (m *IdentifyRequest) XXX_Unmarshal(b []byte) error
type IdentifyResponse ¶
type IdentifyResponse struct {
	// ControllerStatus is the status of the peer controller.
	ControllerStatus     exec.ControllerStatus `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}
    IdentifyResponse is a response to an identify request.
func (*IdentifyResponse) Descriptor ¶
func (*IdentifyResponse) Descriptor() ([]byte, []int)
func (*IdentifyResponse) GetControllerStatus ¶
func (m *IdentifyResponse) GetControllerStatus() exec.ControllerStatus
func (*IdentifyResponse) ProtoMessage ¶
func (*IdentifyResponse) ProtoMessage()
func (*IdentifyResponse) Reset ¶
func (m *IdentifyResponse) Reset()
func (*IdentifyResponse) String ¶
func (m *IdentifyResponse) String() string
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 PeerInfo ¶
type PeerInfo struct {
	// PeerId is the b58 peer ID.
	PeerId               string   `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    PeerInfo is basic information about a peer.
func NewPeerInfo ¶
NewPeerInfo builds peer info from a peer.
func (*PeerInfo) Descriptor ¶
func (*PeerInfo) ProtoMessage ¶
func (*PeerInfo) ProtoMessage()
func (*PeerInfo) XXX_DiscardUnknown ¶
func (m *PeerInfo) XXX_DiscardUnknown()
func (*PeerInfo) XXX_Marshal ¶
func (*PeerInfo) XXX_Unmarshal ¶
type PeerServiceClient ¶
type PeerServiceClient interface {
	// Identify loads and manages a private key identity.
	Identify(ctx context.Context, in *IdentifyRequest, opts ...grpc.CallOption) (PeerService_IdentifyClient, error)
	// GetPeerInfo returns information about attached peers.
	GetPeerInfo(ctx context.Context, in *GetPeerInfoRequest, opts ...grpc.CallOption) (*GetPeerInfoResponse, error)
}
    PeerServiceClient is the client API for PeerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPeerServiceClient ¶
func NewPeerServiceClient(cc grpc.ClientConnInterface) PeerServiceClient
type PeerServiceServer ¶
type PeerServiceServer interface {
	// Identify loads and manages a private key identity.
	Identify(*IdentifyRequest, PeerService_IdentifyServer) error
	// GetPeerInfo returns information about attached peers.
	GetPeerInfo(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)
}
    PeerServiceServer is the server API for PeerService service.
type PeerService_IdentifyClient ¶
type PeerService_IdentifyClient interface {
	Recv() (*IdentifyResponse, error)
	grpc.ClientStream
}
    type PeerService_IdentifyServer ¶
type PeerService_IdentifyServer interface {
	Send(*IdentifyResponse) error
	grpc.ServerStream
}
    type UnimplementedPeerServiceServer ¶
type UnimplementedPeerServiceServer struct {
}
    UnimplementedPeerServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedPeerServiceServer) GetPeerInfo ¶
func (*UnimplementedPeerServiceServer) GetPeerInfo(ctx context.Context, req *GetPeerInfoRequest) (*GetPeerInfoResponse, error)
func (*UnimplementedPeerServiceServer) Identify ¶
func (*UnimplementedPeerServiceServer) Identify(req *IdentifyRequest, srv PeerService_IdentifyServer) error