Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

go_micro_network

package

Go to main page

Versions in this module

v2

v2.9.1

Jul 3, 2020

v2.9.0

Jun 12, 2020

v2.9.0-rc5

Jun 11, 2020

v2.9.0-rc4

Jun 11, 2020

v2.9.0-rc1

Jun 11, 2020

v2.8.0

May 31, 2020

v2.7.0

May 18, 2020

v2.6.0

May 1, 2020

v2.5.0

Apr 15, 2020

Changes in this version

+ func NewNetworkEndpoints() []*api.Endpoint

v2.4.0

Mar 31, 2020

Changes in this version

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

+ 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 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 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)

v2.3.0

Mar 17, 2020

v2.2.0

Feb 28, 2020

v2.1.2

Feb 24, 2020

v2.1.1

Feb 23, 2020

v2.1.0

Feb 13, 2020

v2.0.0

Jan 30, 2020

Changes in this version

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

+ 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 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 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