network

package
v0.10.3 Latest Latest
Warning

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

Go to latest
Published: Jan 29, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthNetwork        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNetwork          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupNetwork = fmt.Errorf("proto: unexpected end of group")
)

Functions

func NewNetworkEndpoints

func NewNetworkEndpoints() []*api.Endpoint

API Endpoints for Network service

func NewNetworkOpenAPI added in v0.8.4

func NewNetworkOpenAPI() *registry.OpenAPI

Swagger OpenAPI 3.0 for Network service

func RegisterNetworkHandler

func RegisterNetworkHandler(s server.Server, hdlr NetworkHandler, opts ...server.HandlerOption) error

func RegisterNetworkServer

func RegisterNetworkServer(s *grpc.Server, srv NetworkServer)

Types

type Close

type Close struct {
	// network node
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
}

Close is sent when the node disconnects from the network

func (*Close) Descriptor

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

func (*Close) GetNode

func (m *Close) GetNode() *Node

func (*Close) Marshal

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

func (*Close) MarshalTo

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

func (*Close) MarshalToSizedBuffer

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

func (*Close) ProtoMessage

func (*Close) ProtoMessage()

func (*Close) Reset

func (m *Close) Reset()

func (*Close) Size

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

func (*Close) String

func (m *Close) String() string

func (*Close) Unmarshal

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

func (*Close) XXX_DiscardUnknown

func (m *Close) XXX_DiscardUnknown()

func (*Close) XXX_Marshal

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

func (*Close) XXX_Merge

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

func (*Close) XXX_Size

func (m *Close) XXX_Size() int

func (*Close) XXX_Unmarshal

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

type Connect

type Connect struct {
	// network mode
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
}

Connect is sent when the node connects to the network

func (*Connect) Descriptor

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

func (*Connect) GetNode

func (m *Connect) GetNode() *Node

func (*Connect) Marshal

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

func (*Connect) MarshalTo

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

func (*Connect) MarshalToSizedBuffer

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

func (*Connect) ProtoMessage

func (*Connect) ProtoMessage()

func (*Connect) Reset

func (m *Connect) Reset()

func (*Connect) Size

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

func (*Connect) String

func (m *Connect) String() string

func (*Connect) Unmarshal

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

func (*Connect) XXX_DiscardUnknown

func (m *Connect) XXX_DiscardUnknown()

func (*Connect) XXX_Marshal

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

func (*Connect) XXX_Merge

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

func (*Connect) XXX_Size

func (m *Connect) XXX_Size() int

func (*Connect) XXX_Unmarshal

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

type ConnectRequest

type ConnectRequest struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*ConnectRequest) Descriptor

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

func (*ConnectRequest) GetNodes

func (m *ConnectRequest) GetNodes() []*Node

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 ConnectResponse

type ConnectResponse struct {
}

func (*ConnectResponse) Descriptor

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

func (*ConnectResponse) Marshal

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

func (*ConnectResponse) MarshalTo

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

func (*ConnectResponse) MarshalToSizedBuffer

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

func (*ConnectResponse) ProtoMessage

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset

func (m *ConnectResponse) Reset()

func (*ConnectResponse) Size

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

func (*ConnectResponse) String

func (m *ConnectResponse) String() string

func (*ConnectResponse) Unmarshal

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

func (*ConnectResponse) XXX_DiscardUnknown

func (m *ConnectResponse) XXX_DiscardUnknown()

func (*ConnectResponse) XXX_Marshal

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

func (*ConnectResponse) XXX_Merge

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

func (*ConnectResponse) XXX_Size

func (m *ConnectResponse) XXX_Size() int

func (*ConnectResponse) XXX_Unmarshal

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

type Error

type Error struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Msg   string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

Error tracks network errors

func (*Error) Descriptor

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

func (*Error) GetCount

func (m *Error) GetCount() uint32

func (*Error) GetMsg

func (m *Error) GetMsg() string

func (*Error) Marshal

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

func (*Error) MarshalTo

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

func (*Error) MarshalToSizedBuffer

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

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

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

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

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

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

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

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

type GraphRequest

type GraphRequest struct {
	// node topology depth
	Depth uint32 `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"`
}

func (*GraphRequest) Descriptor

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

func (*GraphRequest) GetDepth

func (m *GraphRequest) GetDepth() uint32

func (*GraphRequest) Marshal

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

func (*GraphRequest) MarshalTo

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

func (*GraphRequest) MarshalToSizedBuffer

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

func (*GraphRequest) ProtoMessage

func (*GraphRequest) ProtoMessage()

func (*GraphRequest) Reset

func (m *GraphRequest) Reset()

func (*GraphRequest) Size

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

func (*GraphRequest) String

func (m *GraphRequest) String() string

func (*GraphRequest) Unmarshal

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

func (*GraphRequest) XXX_DiscardUnknown

func (m *GraphRequest) XXX_DiscardUnknown()

func (*GraphRequest) XXX_Marshal

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

func (*GraphRequest) XXX_Merge

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

func (*GraphRequest) XXX_Size

func (m *GraphRequest) XXX_Size() int

func (*GraphRequest) XXX_Unmarshal

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

type GraphResponse

type GraphResponse struct {
	Root *Peer `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
}

func (*GraphResponse) Descriptor

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

func (*GraphResponse) GetRoot

func (m *GraphResponse) GetRoot() *Peer

func (*GraphResponse) Marshal

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

func (*GraphResponse) MarshalTo

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

func (*GraphResponse) MarshalToSizedBuffer

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

func (*GraphResponse) ProtoMessage

func (*GraphResponse) ProtoMessage()

func (*GraphResponse) Reset

func (m *GraphResponse) Reset()

func (*GraphResponse) Size

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

func (*GraphResponse) String

func (m *GraphResponse) String() string

func (*GraphResponse) Unmarshal

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

func (*GraphResponse) XXX_DiscardUnknown

func (m *GraphResponse) XXX_DiscardUnknown()

func (*GraphResponse) XXX_Marshal

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

func (*GraphResponse) XXX_Merge

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

func (*GraphResponse) XXX_Size

func (m *GraphResponse) XXX_Size() int

func (*GraphResponse) XXX_Unmarshal

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

type NetworkClient

type NetworkClient interface {
	// Connect to the network
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
	// Returns the entire network graph
	Graph(ctx context.Context, in *GraphRequest, opts ...grpc.CallOption) (*GraphResponse, error)
	// Returns a list of known nodes in the network
	Nodes(ctx context.Context, in *NodesRequest, opts ...grpc.CallOption) (*NodesResponse, error)
	// Returns a list of known routes in the network
	Routes(ctx context.Context, in *RoutesRequest, opts ...grpc.CallOption) (*RoutesResponse, error)
	// Returns a list of known services based on routes
	Services(ctx context.Context, in *ServicesRequest, opts ...grpc.CallOption) (*ServicesResponse, error)
	// Status returns network status
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

NetworkClient is the client API for Network service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNetworkClient

func NewNetworkClient(cc *grpc.ClientConn) NetworkClient

type NetworkHandler

type NetworkHandler interface {
	// Connect to the network
	Connect(context.Context, *ConnectRequest, *ConnectResponse) error
	// Returns the entire network graph
	Graph(context.Context, *GraphRequest, *GraphResponse) error
	// Returns a list of known nodes in the network
	Nodes(context.Context, *NodesRequest, *NodesResponse) error
	// Returns a list of known routes in the network
	Routes(context.Context, *RoutesRequest, *RoutesResponse) error
	// Returns a list of known services based on routes
	Services(context.Context, *ServicesRequest, *ServicesResponse) error
	// Status returns network status
	Status(context.Context, *StatusRequest, *StatusResponse) error
}

Server API for Network service Network service is usesd to gain visibility into networks

type NetworkServer

type NetworkServer interface {
	// Connect to the network
	Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
	// Returns the entire network graph
	Graph(context.Context, *GraphRequest) (*GraphResponse, error)
	// Returns a list of known nodes in the network
	Nodes(context.Context, *NodesRequest) (*NodesResponse, error)
	// Returns a list of known routes in the network
	Routes(context.Context, *RoutesRequest) (*RoutesResponse, error)
	// Returns a list of known services based on routes
	Services(context.Context, *ServicesRequest) (*ServicesResponse, error)
	// Status returns network status
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
}

NetworkServer is the server API for Network service.

type NetworkService

type NetworkService interface {
	// Connect to the network
	Connect(ctx context.Context, in *ConnectRequest, opts ...client.CallOption) (*ConnectResponse, error)
	// Returns the entire network graph
	Graph(ctx context.Context, in *GraphRequest, opts ...client.CallOption) (*GraphResponse, error)
	// Returns a list of known nodes in the network
	Nodes(ctx context.Context, in *NodesRequest, opts ...client.CallOption) (*NodesResponse, error)
	// Returns a list of known routes in the network
	Routes(ctx context.Context, in *RoutesRequest, opts ...client.CallOption) (*RoutesResponse, error)
	// Returns a list of known services based on routes
	Services(ctx context.Context, in *ServicesRequest, opts ...client.CallOption) (*ServicesResponse, error)
	// Status returns network status
	Status(ctx context.Context, in *StatusRequest, opts ...client.CallOption) (*StatusResponse, error)
}

Client API for Network service Network service is usesd to gain visibility into networks

func NewNetworkService

func NewNetworkService(name string, c client.Client) NetworkService

type Node

type Node struct {
	// node id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// node address
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// the network
	Network string `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
	// associated metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// node status
	Status *Status `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
}

Node is network node

func (*Node) Descriptor

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

func (*Node) GetAddress

func (m *Node) GetAddress() string

func (*Node) GetId

func (m *Node) GetId() string

func (*Node) GetMetadata

func (m *Node) GetMetadata() map[string]string

func (*Node) GetNetwork

func (m *Node) GetNetwork() string

func (*Node) GetStatus

func (m *Node) GetStatus() *Status

func (*Node) Marshal

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

func (*Node) MarshalTo

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

func (*Node) MarshalToSizedBuffer

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

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

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

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

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

func (*Node) XXX_DiscardUnknown

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal

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

func (*Node) XXX_Merge

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

func (*Node) XXX_Size

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal

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

type NodesRequest

type NodesRequest struct {
	// node topology depth
	Depth uint32 `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"`
}

PeerRequest requests list of peers

func (*NodesRequest) Descriptor

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

func (*NodesRequest) GetDepth

func (m *NodesRequest) GetDepth() uint32

func (*NodesRequest) Marshal

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

func (*NodesRequest) MarshalTo

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

func (*NodesRequest) MarshalToSizedBuffer

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

func (*NodesRequest) ProtoMessage

func (*NodesRequest) ProtoMessage()

func (*NodesRequest) Reset

func (m *NodesRequest) Reset()

func (*NodesRequest) Size

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

func (*NodesRequest) String

func (m *NodesRequest) String() string

func (*NodesRequest) Unmarshal

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

func (*NodesRequest) XXX_DiscardUnknown

func (m *NodesRequest) XXX_DiscardUnknown()

func (*NodesRequest) XXX_Marshal

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

func (*NodesRequest) XXX_Merge

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

func (*NodesRequest) XXX_Size

func (m *NodesRequest) XXX_Size() int

func (*NodesRequest) XXX_Unmarshal

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

type NodesResponse

type NodesResponse struct {
	// return peer topology
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

PeerResponse is returned by ListPeers

func (*NodesResponse) Descriptor

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

func (*NodesResponse) GetNodes

func (m *NodesResponse) GetNodes() []*Node

func (*NodesResponse) Marshal

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

func (*NodesResponse) MarshalTo

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

func (*NodesResponse) MarshalToSizedBuffer

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

func (*NodesResponse) ProtoMessage

func (*NodesResponse) ProtoMessage()

func (*NodesResponse) Reset

func (m *NodesResponse) Reset()

func (*NodesResponse) Size

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

func (*NodesResponse) String

func (m *NodesResponse) String() string

func (*NodesResponse) Unmarshal

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

func (*NodesResponse) XXX_DiscardUnknown

func (m *NodesResponse) XXX_DiscardUnknown()

func (*NodesResponse) XXX_Marshal

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

func (*NodesResponse) XXX_Merge

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

func (*NodesResponse) XXX_Size

func (m *NodesResponse) XXX_Size() int

func (*NodesResponse) XXX_Unmarshal

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

type Peer

type Peer struct {
	// network node
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// node peers
	Peers []*Peer `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
}

Peer is used to advertise node peers

func (*Peer) Descriptor

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

func (*Peer) GetNode

func (m *Peer) GetNode() *Node

func (*Peer) GetPeers

func (m *Peer) GetPeers() []*Peer

func (*Peer) Marshal

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

func (*Peer) MarshalTo

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

func (*Peer) MarshalToSizedBuffer

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

func (*Peer) ProtoMessage

func (*Peer) ProtoMessage()

func (*Peer) Reset

func (m *Peer) Reset()

func (*Peer) Size

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

func (*Peer) String

func (m *Peer) String() string

func (*Peer) Unmarshal

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

func (*Peer) XXX_DiscardUnknown

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal

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

func (*Peer) XXX_Merge

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

func (*Peer) XXX_Size

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal

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

type Query

type Query struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Gateway string `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
	Router  string `protobuf:"bytes,4,opt,name=router,proto3" json:"router,omitempty"`
	Network string `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"`
}

Query is passed in a LookupRequest

func (*Query) Descriptor

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

func (*Query) GetAddress

func (m *Query) GetAddress() string

func (*Query) GetGateway

func (m *Query) GetGateway() string

func (*Query) GetNetwork

func (m *Query) GetNetwork() string

func (*Query) GetRouter

func (m *Query) GetRouter() string

func (*Query) GetService

func (m *Query) GetService() string

func (*Query) Marshal

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

func (*Query) MarshalTo

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

func (*Query) MarshalToSizedBuffer

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

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) Reset

func (m *Query) Reset()

func (*Query) Size

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

func (*Query) String

func (m *Query) String() string

func (*Query) Unmarshal

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

func (*Query) XXX_DiscardUnknown

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal

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

func (*Query) XXX_Merge

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

func (*Query) XXX_Size

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal

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

type RoutesRequest

type RoutesRequest struct {
	// filter based on
	Query *Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
}

func (*RoutesRequest) Descriptor

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

func (*RoutesRequest) GetQuery

func (m *RoutesRequest) GetQuery() *Query

func (*RoutesRequest) Marshal

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

func (*RoutesRequest) MarshalTo

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

func (*RoutesRequest) MarshalToSizedBuffer

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

func (*RoutesRequest) ProtoMessage

func (*RoutesRequest) ProtoMessage()

func (*RoutesRequest) Reset

func (m *RoutesRequest) Reset()

func (*RoutesRequest) Size

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

func (*RoutesRequest) String

func (m *RoutesRequest) String() string

func (*RoutesRequest) Unmarshal

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

func (*RoutesRequest) XXX_DiscardUnknown

func (m *RoutesRequest) XXX_DiscardUnknown()

func (*RoutesRequest) XXX_Marshal

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

func (*RoutesRequest) XXX_Merge

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

func (*RoutesRequest) XXX_Size

func (m *RoutesRequest) XXX_Size() int

func (*RoutesRequest) XXX_Unmarshal

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

type RoutesResponse

type RoutesResponse struct {
	Routes []*router.Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
}

func (*RoutesResponse) Descriptor

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

func (*RoutesResponse) GetRoutes

func (m *RoutesResponse) GetRoutes() []*router.Route

func (*RoutesResponse) Marshal

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

func (*RoutesResponse) MarshalTo

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

func (*RoutesResponse) MarshalToSizedBuffer

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

func (*RoutesResponse) ProtoMessage

func (*RoutesResponse) ProtoMessage()

func (*RoutesResponse) Reset

func (m *RoutesResponse) Reset()

func (*RoutesResponse) Size

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

func (*RoutesResponse) String

func (m *RoutesResponse) String() string

func (*RoutesResponse) Unmarshal

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

func (*RoutesResponse) XXX_DiscardUnknown

func (m *RoutesResponse) XXX_DiscardUnknown()

func (*RoutesResponse) XXX_Marshal

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

func (*RoutesResponse) XXX_Merge

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

func (*RoutesResponse) XXX_Size

func (m *RoutesResponse) XXX_Size() int

func (*RoutesResponse) XXX_Unmarshal

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

type ServicesRequest

type ServicesRequest struct {
}

func (*ServicesRequest) Descriptor

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

func (*ServicesRequest) Marshal

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

func (*ServicesRequest) MarshalTo

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

func (*ServicesRequest) MarshalToSizedBuffer

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

func (*ServicesRequest) ProtoMessage

func (*ServicesRequest) ProtoMessage()

func (*ServicesRequest) Reset

func (m *ServicesRequest) Reset()

func (*ServicesRequest) Size

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

func (*ServicesRequest) String

func (m *ServicesRequest) String() string

func (*ServicesRequest) Unmarshal

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

func (*ServicesRequest) XXX_DiscardUnknown

func (m *ServicesRequest) XXX_DiscardUnknown()

func (*ServicesRequest) XXX_Marshal

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

func (*ServicesRequest) XXX_Merge

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

func (*ServicesRequest) XXX_Size

func (m *ServicesRequest) XXX_Size() int

func (*ServicesRequest) XXX_Unmarshal

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

type ServicesResponse

type ServicesResponse struct {
	Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
}

func (*ServicesResponse) Descriptor

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

func (*ServicesResponse) GetServices

func (m *ServicesResponse) GetServices() []string

func (*ServicesResponse) Marshal

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

func (*ServicesResponse) MarshalTo

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

func (*ServicesResponse) MarshalToSizedBuffer

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

func (*ServicesResponse) ProtoMessage

func (*ServicesResponse) ProtoMessage()

func (*ServicesResponse) Reset

func (m *ServicesResponse) Reset()

func (*ServicesResponse) Size

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

func (*ServicesResponse) String

func (m *ServicesResponse) String() string

func (*ServicesResponse) Unmarshal

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

func (*ServicesResponse) XXX_DiscardUnknown

func (m *ServicesResponse) XXX_DiscardUnknown()

func (*ServicesResponse) XXX_Marshal

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

func (*ServicesResponse) XXX_Merge

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

func (*ServicesResponse) XXX_Size

func (m *ServicesResponse) XXX_Size() int

func (*ServicesResponse) XXX_Unmarshal

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

type Status

type Status struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

Status is node status

func (*Status) Descriptor

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

func (*Status) GetError

func (m *Status) GetError() *Error

func (*Status) Marshal

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

func (*Status) MarshalTo

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

func (*Status) MarshalToSizedBuffer

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

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) Size

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

func (*Status) String

func (m *Status) String() string

func (*Status) Unmarshal

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

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

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

func (*Status) XXX_Merge

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

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

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

type StatusRequest

type StatusRequest struct {
}

func (*StatusRequest) Descriptor

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

func (*StatusRequest) Marshal

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

func (*StatusRequest) MarshalTo

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

func (*StatusRequest) MarshalToSizedBuffer

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

func (*StatusRequest) ProtoMessage

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset

func (m *StatusRequest) Reset()

func (*StatusRequest) Size

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

func (*StatusRequest) String

func (m *StatusRequest) String() string

func (*StatusRequest) Unmarshal

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

func (*StatusRequest) XXX_DiscardUnknown

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal

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

func (*StatusRequest) XXX_Merge

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

func (*StatusRequest) XXX_Size

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal

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

type StatusResponse

type StatusResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*StatusResponse) Descriptor

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

func (*StatusResponse) GetStatus

func (m *StatusResponse) GetStatus() *Status

func (*StatusResponse) Marshal

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

func (*StatusResponse) MarshalTo

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

func (*StatusResponse) MarshalToSizedBuffer

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

func (*StatusResponse) ProtoMessage

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset

func (m *StatusResponse) Reset()

func (*StatusResponse) Size

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

func (*StatusResponse) String

func (m *StatusResponse) String() string

func (*StatusResponse) Unmarshal

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

func (*StatusResponse) XXX_DiscardUnknown

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal

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

func (*StatusResponse) XXX_Merge

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

func (*StatusResponse) XXX_Size

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal

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

type Sync

type Sync struct {
	// peer origin
	Peer *Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	// node routes
	Routes []*router.Route `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
}

Sync is network sync message

func (*Sync) Descriptor

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

func (*Sync) GetPeer

func (m *Sync) GetPeer() *Peer

func (*Sync) GetRoutes

func (m *Sync) GetRoutes() []*router.Route

func (*Sync) Marshal

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

func (*Sync) MarshalTo

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

func (*Sync) MarshalToSizedBuffer

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

func (*Sync) ProtoMessage

func (*Sync) ProtoMessage()

func (*Sync) Reset

func (m *Sync) Reset()

func (*Sync) Size

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

func (*Sync) String

func (m *Sync) String() string

func (*Sync) Unmarshal

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

func (*Sync) XXX_DiscardUnknown

func (m *Sync) XXX_DiscardUnknown()

func (*Sync) XXX_Marshal

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

func (*Sync) XXX_Merge

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

func (*Sync) XXX_Size

func (m *Sync) XXX_Size() int

func (*Sync) XXX_Unmarshal

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

type UnimplementedNetworkServer

type UnimplementedNetworkServer struct {
}

UnimplementedNetworkServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServer) Connect

func (*UnimplementedNetworkServer) Graph

func (*UnimplementedNetworkServer) Nodes

func (*UnimplementedNetworkServer) Routes

func (*UnimplementedNetworkServer) Services

func (*UnimplementedNetworkServer) Status

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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