network

package

Go to main page

Versions in this module

v3

v3.9.0

Sep 13, 2022

v3.8.9

Sep 9, 2022

v3.8.8

Aug 31, 2022

v3.8.7

Jun 13, 2022

v3.8.6

Apr 1, 2022

v3.8.5

Feb 18, 2022

v3.8.4

Feb 10, 2022

v3.8.3

Jan 13, 2022

Changes in this version

+ var File_proto_network_network_proto protoreflect.FileDescriptor

type Close

+ func (x *Close) ProtoReflect() protoreflect.Message

type Connect

+ func (x *Connect) ProtoReflect() protoreflect.Message

type ConnectRequest

+ func (x *ConnectRequest) ProtoReflect() protoreflect.Message

type ConnectResponse

+ func (x *ConnectResponse) ProtoReflect() protoreflect.Message

type Error

+ func (x *Error) ProtoReflect() protoreflect.Message

type GraphRequest

+ func (x *GraphRequest) ProtoReflect() protoreflect.Message

type GraphResponse

+ func (x *GraphResponse) ProtoReflect() protoreflect.Message

type Node

+ func (x *Node) ProtoReflect() protoreflect.Message

type NodesRequest

+ func (x *NodesRequest) ProtoReflect() protoreflect.Message

type NodesResponse

+ func (x *NodesResponse) ProtoReflect() protoreflect.Message

type Peer

+ func (x *Peer) ProtoReflect() protoreflect.Message

type Query

+ func (x *Query) ProtoReflect() protoreflect.Message

type RoutesRequest

+ func (x *RoutesRequest) ProtoReflect() protoreflect.Message

type RoutesResponse

+ func (x *RoutesResponse) ProtoReflect() protoreflect.Message

type ServicesRequest

+ func (x *ServicesRequest) ProtoReflect() protoreflect.Message

type ServicesResponse

+ func (x *ServicesResponse) ProtoReflect() protoreflect.Message

type Status

+ func (x *Status) ProtoReflect() protoreflect.Message

type StatusRequest

+ func (x *StatusRequest) ProtoReflect() protoreflect.Message

type StatusResponse

+ func (x *StatusResponse) ProtoReflect() protoreflect.Message

type Sync

+ func (x *Sync) ProtoReflect() protoreflect.Message

+ type UnimplementedNetworkServer struct

+ func (*UnimplementedNetworkServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

+ func (*UnimplementedNetworkServer) Graph(context.Context, *GraphRequest) (*GraphResponse, error)

+ func (*UnimplementedNetworkServer) Nodes(context.Context, *NodesRequest) (*NodesResponse, error)

+ func (*UnimplementedNetworkServer) Routes(context.Context, *RoutesRequest) (*RoutesResponse, error)

+ func (*UnimplementedNetworkServer) Services(context.Context, *ServicesRequest) (*ServicesResponse, error)

+ func (*UnimplementedNetworkServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

v3.8.2

Dec 15, 2021

v3.8.1

Dec 15, 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 []*router.Route

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RoutesResponse) Descriptor() ([]byte, []int)

+ func (*RoutesResponse) ProtoMessage()

+ func (m *RoutesResponse) GetRoutes() []*router.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 []*router.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() []*router.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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL