Versions in this module Expand all Collapse all v2 v2.9.3 Mar 2, 2021 v2.9.2 Mar 2, 2021 Changes in this version + func NewNetworkEndpoints() []*api.Endpoint + func RegisterNetworkHandler(s server.Server, hdlr NetworkHandler, opts ...server.HandlerOption) error + func RegisterNetworkServer(s *grpc.Server, srv NetworkServer) + type Close struct + Node *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Close) Descriptor() ([]byte, []int) + func (*Close) ProtoMessage() + func (m *Close) GetNode() *Node + func (m *Close) Reset() + func (m *Close) String() string + func (m *Close) XXX_DiscardUnknown() + func (m *Close) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Close) XXX_Merge(src proto.Message) + func (m *Close) XXX_Size() int + func (m *Close) XXX_Unmarshal(b []byte) error + type Connect struct + Node *Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Connect) Descriptor() ([]byte, []int) + func (*Connect) ProtoMessage() + func (m *Connect) GetNode() *Node + func (m *Connect) Reset() + func (m *Connect) String() string + func (m *Connect) XXX_DiscardUnknown() + func (m *Connect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connect) XXX_Merge(src proto.Message) + func (m *Connect) XXX_Size() int + func (m *Connect) XXX_Unmarshal(b []byte) error + type ConnectRequest struct + Nodes []*Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConnectRequest) Descriptor() ([]byte, []int) + func (*ConnectRequest) ProtoMessage() + func (m *ConnectRequest) GetNodes() []*Node + func (m *ConnectRequest) Reset() + func (m *ConnectRequest) String() string + func (m *ConnectRequest) XXX_DiscardUnknown() + func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConnectRequest) XXX_Merge(src proto.Message) + func (m *ConnectRequest) XXX_Size() int + func (m *ConnectRequest) XXX_Unmarshal(b []byte) error + type ConnectResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConnectResponse) Descriptor() ([]byte, []int) + func (*ConnectResponse) ProtoMessage() + func (m *ConnectResponse) Reset() + func (m *ConnectResponse) String() string + func (m *ConnectResponse) XXX_DiscardUnknown() + func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConnectResponse) XXX_Merge(src proto.Message) + func (m *ConnectResponse) XXX_Size() int + func (m *ConnectResponse) XXX_Unmarshal(b []byte) error + type Error struct + Count uint32 + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetCount() uint32 + func (m *Error) GetMsg() string + func (m *Error) Reset() + func (m *Error) String() string + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type GraphRequest struct + Depth uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GraphRequest) Descriptor() ([]byte, []int) + func (*GraphRequest) ProtoMessage() + func (m *GraphRequest) GetDepth() uint32 + func (m *GraphRequest) Reset() + func (m *GraphRequest) String() string + func (m *GraphRequest) XXX_DiscardUnknown() + func (m *GraphRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GraphRequest) XXX_Merge(src proto.Message) + func (m *GraphRequest) XXX_Size() int + func (m *GraphRequest) XXX_Unmarshal(b []byte) error + type GraphResponse struct + Root *Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GraphResponse) Descriptor() ([]byte, []int) + func (*GraphResponse) ProtoMessage() + func (m *GraphResponse) GetRoot() *Peer + func (m *GraphResponse) Reset() + func (m *GraphResponse) String() string + func (m *GraphResponse) XXX_DiscardUnknown() + func (m *GraphResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GraphResponse) XXX_Merge(src proto.Message) + func (m *GraphResponse) XXX_Size() int + func (m *GraphResponse) XXX_Unmarshal(b []byte) error + type NetworkClient interface + Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error) + Graph func(ctx context.Context, in *GraphRequest, opts ...grpc.CallOption) (*GraphResponse, error) + Nodes func(ctx context.Context, in *NodesRequest, opts ...grpc.CallOption) (*NodesResponse, error) + Routes func(ctx context.Context, in *RoutesRequest, opts ...grpc.CallOption) (*RoutesResponse, error) + Services func(ctx context.Context, in *ServicesRequest, opts ...grpc.CallOption) (*ServicesResponse, error) + Status func(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) + func NewNetworkClient(cc *grpc.ClientConn) NetworkClient + type NetworkHandler interface + Connect func(context.Context, *ConnectRequest, *ConnectResponse) error + Graph func(context.Context, *GraphRequest, *GraphResponse) error + Nodes func(context.Context, *NodesRequest, *NodesResponse) error + Routes func(context.Context, *RoutesRequest, *RoutesResponse) error + Services func(context.Context, *ServicesRequest, *ServicesResponse) error + Status func(context.Context, *StatusRequest, *StatusResponse) error + type NetworkServer interface + Connect func(context.Context, *ConnectRequest) (*ConnectResponse, error) + Graph func(context.Context, *GraphRequest) (*GraphResponse, error) + Nodes func(context.Context, *NodesRequest) (*NodesResponse, error) + Routes func(context.Context, *RoutesRequest) (*RoutesResponse, error) + Services func(context.Context, *ServicesRequest) (*ServicesResponse, error) + Status func(context.Context, *StatusRequest) (*StatusResponse, error) + type NetworkService interface + Connect func(ctx context.Context, in *ConnectRequest, opts ...client.CallOption) (*ConnectResponse, error) + Graph func(ctx context.Context, in *GraphRequest, opts ...client.CallOption) (*GraphResponse, error) + Nodes func(ctx context.Context, in *NodesRequest, opts ...client.CallOption) (*NodesResponse, error) + Routes func(ctx context.Context, in *RoutesRequest, opts ...client.CallOption) (*RoutesResponse, error) + Services func(ctx context.Context, in *ServicesRequest, opts ...client.CallOption) (*ServicesResponse, error) + Status func(ctx context.Context, in *StatusRequest, opts ...client.CallOption) (*StatusResponse, error) + func NewNetworkService(name string, c client.Client) NetworkService + type Node struct + Address string + Id string + Metadata map[string]string + Network string + Status *Status + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetAddress() string + func (m *Node) GetId() string + func (m *Node) GetMetadata() map[string]string + func (m *Node) GetNetwork() string + func (m *Node) GetStatus() *Status + func (m *Node) Reset() + func (m *Node) String() string + func (m *Node) XXX_DiscardUnknown() + func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Node) XXX_Merge(src proto.Message) + func (m *Node) XXX_Size() int + func (m *Node) XXX_Unmarshal(b []byte) error + type NodesRequest struct + Depth uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodesRequest) Descriptor() ([]byte, []int) + func (*NodesRequest) ProtoMessage() + func (m *NodesRequest) GetDepth() uint32 + func (m *NodesRequest) Reset() + func (m *NodesRequest) String() string + func (m *NodesRequest) XXX_DiscardUnknown() + func (m *NodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodesRequest) XXX_Merge(src proto.Message) + func (m *NodesRequest) XXX_Size() int + func (m *NodesRequest) XXX_Unmarshal(b []byte) error + type NodesResponse struct + Nodes []*Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodesResponse) Descriptor() ([]byte, []int) + func (*NodesResponse) ProtoMessage() + func (m *NodesResponse) GetNodes() []*Node + func (m *NodesResponse) Reset() + func (m *NodesResponse) String() string + func (m *NodesResponse) XXX_DiscardUnknown() + func (m *NodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodesResponse) XXX_Merge(src proto.Message) + func (m *NodesResponse) XXX_Size() int + func (m *NodesResponse) XXX_Unmarshal(b []byte) error + type Peer struct + Node *Node + Peers []*Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (m *Peer) GetNode() *Node + func (m *Peer) GetPeers() []*Peer + func (m *Peer) Reset() + func (m *Peer) String() string + func (m *Peer) XXX_DiscardUnknown() + func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Peer) XXX_Merge(src proto.Message) + func (m *Peer) XXX_Size() int + func (m *Peer) XXX_Unmarshal(b []byte) error + type Query struct + Address string + Gateway string + Network string + Router string + Service string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetAddress() string + func (m *Query) GetGateway() string + func (m *Query) GetNetwork() string + func (m *Query) GetRouter() string + func (m *Query) GetService() string + func (m *Query) Reset() + func (m *Query) String() string + func (m *Query) XXX_DiscardUnknown() + func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Query) XXX_Merge(src proto.Message) + func (m *Query) XXX_Size() int + func (m *Query) XXX_Unmarshal(b []byte) error + type RoutesRequest struct + Query *Query + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RoutesRequest) Descriptor() ([]byte, []int) + func (*RoutesRequest) ProtoMessage() + func (m *RoutesRequest) GetQuery() *Query + func (m *RoutesRequest) Reset() + func (m *RoutesRequest) String() string + func (m *RoutesRequest) XXX_DiscardUnknown() + func (m *RoutesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RoutesRequest) XXX_Merge(src proto.Message) + func (m *RoutesRequest) XXX_Size() int + func (m *RoutesRequest) XXX_Unmarshal(b []byte) error + type RoutesResponse struct + Routes []*proto1.Route + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RoutesResponse) Descriptor() ([]byte, []int) + func (*RoutesResponse) ProtoMessage() + func (m *RoutesResponse) GetRoutes() []*proto1.Route + func (m *RoutesResponse) Reset() + func (m *RoutesResponse) String() string + func (m *RoutesResponse) XXX_DiscardUnknown() + func (m *RoutesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RoutesResponse) XXX_Merge(src proto.Message) + func (m *RoutesResponse) XXX_Size() int + func (m *RoutesResponse) XXX_Unmarshal(b []byte) error + type ServicesRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServicesRequest) Descriptor() ([]byte, []int) + func (*ServicesRequest) ProtoMessage() + func (m *ServicesRequest) Reset() + func (m *ServicesRequest) String() string + func (m *ServicesRequest) XXX_DiscardUnknown() + func (m *ServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServicesRequest) XXX_Merge(src proto.Message) + func (m *ServicesRequest) XXX_Size() int + func (m *ServicesRequest) XXX_Unmarshal(b []byte) error + type ServicesResponse struct + Services []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServicesResponse) Descriptor() ([]byte, []int) + func (*ServicesResponse) ProtoMessage() + func (m *ServicesResponse) GetServices() []string + func (m *ServicesResponse) Reset() + func (m *ServicesResponse) String() string + func (m *ServicesResponse) XXX_DiscardUnknown() + func (m *ServicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServicesResponse) XXX_Merge(src proto.Message) + func (m *ServicesResponse) XXX_Size() int + func (m *ServicesResponse) XXX_Unmarshal(b []byte) error + type Status struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Status) Descriptor() ([]byte, []int) + func (*Status) ProtoMessage() + func (m *Status) GetError() *Error + func (m *Status) Reset() + func (m *Status) String() string + func (m *Status) XXX_DiscardUnknown() + func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Status) XXX_Merge(src proto.Message) + func (m *Status) XXX_Size() int + func (m *Status) XXX_Unmarshal(b []byte) error + type StatusRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatusRequest) Descriptor() ([]byte, []int) + func (*StatusRequest) ProtoMessage() + func (m *StatusRequest) Reset() + func (m *StatusRequest) String() string + func (m *StatusRequest) XXX_DiscardUnknown() + func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatusRequest) XXX_Merge(src proto.Message) + func (m *StatusRequest) XXX_Size() int + func (m *StatusRequest) XXX_Unmarshal(b []byte) error + type StatusResponse struct + Status *Status + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatusResponse) Descriptor() ([]byte, []int) + func (*StatusResponse) ProtoMessage() + func (m *StatusResponse) GetStatus() *Status + func (m *StatusResponse) Reset() + func (m *StatusResponse) String() string + func (m *StatusResponse) XXX_DiscardUnknown() + func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatusResponse) XXX_Merge(src proto.Message) + func (m *StatusResponse) XXX_Size() int + func (m *StatusResponse) XXX_Unmarshal(b []byte) error + type Sync struct + Peer *Peer + Routes []*proto1.Route + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Sync) Descriptor() ([]byte, []int) + func (*Sync) ProtoMessage() + func (m *Sync) GetPeer() *Peer + func (m *Sync) GetRoutes() []*proto1.Route + func (m *Sync) Reset() + func (m *Sync) String() string + func (m *Sync) XXX_DiscardUnknown() + func (m *Sync) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Sync) XXX_Merge(src proto.Message) + func (m *Sync) XXX_Size() int + func (m *Sync) XXX_Unmarshal(b []byte) error + type UnimplementedNetworkServer struct + func (*UnimplementedNetworkServer) Connect(ctx context.Context, req *ConnectRequest) (*ConnectResponse, error) + func (*UnimplementedNetworkServer) Graph(ctx context.Context, req *GraphRequest) (*GraphResponse, error) + func (*UnimplementedNetworkServer) Nodes(ctx context.Context, req *NodesRequest) (*NodesResponse, error) + func (*UnimplementedNetworkServer) Routes(ctx context.Context, req *RoutesRequest) (*RoutesResponse, error) + func (*UnimplementedNetworkServer) Services(ctx context.Context, req *ServicesRequest) (*ServicesResponse, error) + func (*UnimplementedNetworkServer) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)
Go to main page