Versions in this module Expand all Collapse all v0 v0.1.0 Jan 24, 2022 Changes in this version + var ControlPlane_ServiceDesc = grpc.ServiceDesc + var File_api_control_plane_proto protoreflect.FileDescriptor + var PeerConnectionState_name = map[int32]string + var PeerConnectionState_value = map[string]int32 + func RegisterControlPlaneHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterControlPlaneHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControlPlaneClient) error + func RegisterControlPlaneHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterControlPlaneHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControlPlaneServer) error + func RegisterControlPlaneServer(s grpc.ServiceRegistrar, srv ControlPlaneServer) + type ControlPlaneClient interface + GetPeers func(ctx context.Context, in *GetPeersRequest, opts ...grpc.CallOption) (*GetPeersResponse, error) + GetSelf func(ctx context.Context, in *GetSelfRequest, opts ...grpc.CallOption) (*GetSelfResponse, error) + func NewControlPlaneClient(cc grpc.ClientConnInterface) ControlPlaneClient + type ControlPlaneServer interface + GetPeers func(context.Context, *GetPeersRequest) (*GetPeersResponse, error) + GetSelf func(context.Context, *GetSelfRequest) (*GetSelfResponse, error) + type GetPeersRequest struct + State *PeerConnectionState + func (*GetPeersRequest) Descriptor() ([]byte, []int) + func (*GetPeersRequest) ProtoMessage() + func (x *GetPeersRequest) GetState() PeerConnectionState + func (x *GetPeersRequest) ProtoReflect() protoreflect.Message + func (x *GetPeersRequest) Reset() + func (x *GetPeersRequest) String() string + type GetPeersResponse struct + Peers []*PeerConnection + func (*GetPeersResponse) Descriptor() ([]byte, []int) + func (*GetPeersResponse) ProtoMessage() + func (x *GetPeersResponse) GetPeers() []*PeerConnection + func (x *GetPeersResponse) ProtoReflect() protoreflect.Message + func (x *GetPeersResponse) Reset() + func (x *GetPeersResponse) String() string + type GetSelfRequest struct + func (*GetSelfRequest) Descriptor() ([]byte, []int) + func (*GetSelfRequest) ProtoMessage() + func (x *GetSelfRequest) ProtoReflect() protoreflect.Message + func (x *GetSelfRequest) Reset() + func (x *GetSelfRequest) String() string + type GetSelfResponse struct + Peer *Peer + PeerCount uint32 + StartTime *timestamppb.Timestamp + func (*GetSelfResponse) Descriptor() ([]byte, []int) + func (*GetSelfResponse) ProtoMessage() + func (x *GetSelfResponse) GetPeer() *Peer + func (x *GetSelfResponse) GetPeerCount() uint32 + func (x *GetSelfResponse) GetStartTime() *timestamppb.Timestamp + func (x *GetSelfResponse) ProtoReflect() protoreflect.Message + func (x *GetSelfResponse) Reset() + func (x *GetSelfResponse) String() string + type Peer struct + ConnectTime *timestamppb.Timestamp + Enr string + PeerId string + Version string + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (x *Peer) GetConnectTime() *timestamppb.Timestamp + func (x *Peer) GetEnr() string + func (x *Peer) GetPeerId() string + func (x *Peer) GetVersion() string + func (x *Peer) ProtoReflect() protoreflect.Message + func (x *Peer) Reset() + func (x *Peer) String() string + type PeerConnection struct + Endpoint string + Incoming bool + Peer *Peer + State PeerConnectionState + func (*PeerConnection) Descriptor() ([]byte, []int) + func (*PeerConnection) ProtoMessage() + func (x *PeerConnection) GetEndpoint() string + func (x *PeerConnection) GetIncoming() bool + func (x *PeerConnection) GetPeer() *Peer + func (x *PeerConnection) GetState() PeerConnectionState + func (x *PeerConnection) ProtoReflect() protoreflect.Message + func (x *PeerConnection) Reset() + func (x *PeerConnection) String() string + type PeerConnectionState int32 + const PeerConnectionState_CONNECTED + const PeerConnectionState_CONNECTING + const PeerConnectionState_DISCONNECTED + const PeerConnectionState_DISCONNECTING + func (PeerConnectionState) Descriptor() protoreflect.EnumDescriptor + func (PeerConnectionState) EnumDescriptor() ([]byte, []int) + func (PeerConnectionState) Type() protoreflect.EnumType + func (x PeerConnectionState) Enum() *PeerConnectionState + func (x PeerConnectionState) Number() protoreflect.EnumNumber + func (x PeerConnectionState) String() string + type UnimplementedControlPlaneServer struct + func (UnimplementedControlPlaneServer) GetPeers(context.Context, *GetPeersRequest) (*GetPeersResponse, error) + func (UnimplementedControlPlaneServer) GetSelf(context.Context, *GetSelfRequest) (*GetSelfResponse, error) + type UnsafeControlPlaneServer interface
Go to main page