go-micro: github.com/micro/go-micro/network/service/proto Index | Files

package go_micro_network

import "github.com/micro/go-micro/network/service/proto"

Index

Package Files

network.pb.go network.pb.micro.go

func RegisterNetworkHandler Uses

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

type Close Uses

type Close struct {
    // network node
    Node                 *Node    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Close is sent when the node disconnects from the network

func (*Close) Descriptor Uses

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

func (*Close) GetNode Uses

func (m *Close) GetNode() *Node

func (*Close) ProtoMessage Uses

func (*Close) ProtoMessage()

func (*Close) Reset Uses

func (m *Close) Reset()

func (*Close) String Uses

func (m *Close) String() string

func (*Close) XXX_DiscardUnknown Uses

func (m *Close) XXX_DiscardUnknown()

func (*Close) XXX_Marshal Uses

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

func (*Close) XXX_Merge Uses

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

func (*Close) XXX_Size Uses

func (m *Close) XXX_Size() int

func (*Close) XXX_Unmarshal Uses

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

type Connect Uses

type Connect struct {
    // network mode
    Node                 *Node    `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Connect is sent when the node connects to the network

func (*Connect) Descriptor Uses

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

func (*Connect) GetNode Uses

func (m *Connect) GetNode() *Node

func (*Connect) ProtoMessage Uses

func (*Connect) ProtoMessage()

func (*Connect) Reset Uses

func (m *Connect) Reset()

func (*Connect) String Uses

func (m *Connect) String() string

func (*Connect) XXX_DiscardUnknown Uses

func (m *Connect) XXX_DiscardUnknown()

func (*Connect) XXX_Marshal Uses

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

func (*Connect) XXX_Merge Uses

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

func (*Connect) XXX_Size Uses

func (m *Connect) XXX_Size() int

func (*Connect) XXX_Unmarshal Uses

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

type ConnectRequest Uses

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

func (*ConnectRequest) Descriptor Uses

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

func (*ConnectRequest) GetNodes Uses

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

func (*ConnectRequest) ProtoMessage Uses

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset Uses

func (m *ConnectRequest) Reset()

func (*ConnectRequest) String Uses

func (m *ConnectRequest) String() string

func (*ConnectRequest) XXX_DiscardUnknown Uses

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal Uses

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

func (*ConnectRequest) XXX_Merge Uses

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

func (*ConnectRequest) XXX_Size Uses

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal Uses

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

type ConnectResponse Uses

type ConnectResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ConnectResponse) Descriptor Uses

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

func (*ConnectResponse) ProtoMessage Uses

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset Uses

func (m *ConnectResponse) Reset()

func (*ConnectResponse) String Uses

func (m *ConnectResponse) String() string

func (*ConnectResponse) XXX_DiscardUnknown Uses

func (m *ConnectResponse) XXX_DiscardUnknown()

func (*ConnectResponse) XXX_Marshal Uses

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

func (*ConnectResponse) XXX_Merge Uses

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

func (*ConnectResponse) XXX_Size Uses

func (m *ConnectResponse) XXX_Size() int

func (*ConnectResponse) XXX_Unmarshal Uses

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

type Error Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Error tracks network errors

func (*Error) Descriptor Uses

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

func (*Error) GetCount Uses

func (m *Error) GetCount() uint32

func (*Error) GetMsg Uses

func (m *Error) GetMsg() string

func (*Error) ProtoMessage Uses

func (*Error) ProtoMessage()

func (*Error) Reset Uses

func (m *Error) Reset()

func (*Error) String Uses

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown Uses

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal Uses

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

func (*Error) XXX_Merge Uses

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

func (*Error) XXX_Size Uses

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal Uses

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

type GraphRequest Uses

type GraphRequest struct {
    // node topology depth
    Depth                uint32   `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GraphRequest) Descriptor Uses

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

func (*GraphRequest) GetDepth Uses

func (m *GraphRequest) GetDepth() uint32

func (*GraphRequest) ProtoMessage Uses

func (*GraphRequest) ProtoMessage()

func (*GraphRequest) Reset Uses

func (m *GraphRequest) Reset()

func (*GraphRequest) String Uses

func (m *GraphRequest) String() string

func (*GraphRequest) XXX_DiscardUnknown Uses

func (m *GraphRequest) XXX_DiscardUnknown()

func (*GraphRequest) XXX_Marshal Uses

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

func (*GraphRequest) XXX_Merge Uses

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

func (*GraphRequest) XXX_Size Uses

func (m *GraphRequest) XXX_Size() int

func (*GraphRequest) XXX_Unmarshal Uses

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

type GraphResponse Uses

type GraphResponse struct {
    Root                 *Peer    `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GraphResponse) Descriptor Uses

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

func (*GraphResponse) GetRoot Uses

func (m *GraphResponse) GetRoot() *Peer

func (*GraphResponse) ProtoMessage Uses

func (*GraphResponse) ProtoMessage()

func (*GraphResponse) Reset Uses

func (m *GraphResponse) Reset()

func (*GraphResponse) String Uses

func (m *GraphResponse) String() string

func (*GraphResponse) XXX_DiscardUnknown Uses

func (m *GraphResponse) XXX_DiscardUnknown()

func (*GraphResponse) XXX_Marshal Uses

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

func (*GraphResponse) XXX_Merge Uses

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

func (*GraphResponse) XXX_Size Uses

func (m *GraphResponse) XXX_Size() int

func (*GraphResponse) XXX_Unmarshal Uses

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

type NetworkHandler Uses

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
}

type NetworkService Uses

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

func NewNetworkService Uses

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

type Node Uses

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 `protobuf:"bytes,4,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // node status
    Status               *Status  `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Node is network node

func (*Node) Descriptor Uses

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

func (*Node) GetAddress Uses

func (m *Node) GetAddress() string

func (*Node) GetId Uses

func (m *Node) GetId() string

func (*Node) GetMetadata Uses

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

func (*Node) GetNetwork Uses

func (m *Node) GetNetwork() string

func (*Node) GetStatus Uses

func (m *Node) GetStatus() *Status

func (*Node) ProtoMessage Uses

func (*Node) ProtoMessage()

func (*Node) Reset Uses

func (m *Node) Reset()

func (*Node) String Uses

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown Uses

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal Uses

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

func (*Node) XXX_Merge Uses

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

func (*Node) XXX_Size Uses

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal Uses

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

type NodesRequest Uses

type NodesRequest struct {
    // node topology depth
    Depth                uint32   `protobuf:"varint,1,opt,name=depth,proto3" json:"depth,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PeerRequest requests list of peers

func (*NodesRequest) Descriptor Uses

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

func (*NodesRequest) GetDepth Uses

func (m *NodesRequest) GetDepth() uint32

func (*NodesRequest) ProtoMessage Uses

func (*NodesRequest) ProtoMessage()

func (*NodesRequest) Reset Uses

func (m *NodesRequest) Reset()

func (*NodesRequest) String Uses

func (m *NodesRequest) String() string

func (*NodesRequest) XXX_DiscardUnknown Uses

func (m *NodesRequest) XXX_DiscardUnknown()

func (*NodesRequest) XXX_Marshal Uses

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

func (*NodesRequest) XXX_Merge Uses

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

func (*NodesRequest) XXX_Size Uses

func (m *NodesRequest) XXX_Size() int

func (*NodesRequest) XXX_Unmarshal Uses

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

type NodesResponse Uses

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

PeerResponse is returned by ListPeers

func (*NodesResponse) Descriptor Uses

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

func (*NodesResponse) GetNodes Uses

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

func (*NodesResponse) ProtoMessage Uses

func (*NodesResponse) ProtoMessage()

func (*NodesResponse) Reset Uses

func (m *NodesResponse) Reset()

func (*NodesResponse) String Uses

func (m *NodesResponse) String() string

func (*NodesResponse) XXX_DiscardUnknown Uses

func (m *NodesResponse) XXX_DiscardUnknown()

func (*NodesResponse) XXX_Marshal Uses

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

func (*NodesResponse) XXX_Merge Uses

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

func (*NodesResponse) XXX_Size Uses

func (m *NodesResponse) XXX_Size() int

func (*NodesResponse) XXX_Unmarshal Uses

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

type Peer Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Peer is used to advertise node peers

func (*Peer) Descriptor Uses

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

func (*Peer) GetNode Uses

func (m *Peer) GetNode() *Node

func (*Peer) GetPeers Uses

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

func (*Peer) ProtoMessage Uses

func (*Peer) ProtoMessage()

func (*Peer) Reset Uses

func (m *Peer) Reset()

func (*Peer) String Uses

func (m *Peer) String() string

func (*Peer) XXX_DiscardUnknown Uses

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal Uses

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

func (*Peer) XXX_Merge Uses

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

func (*Peer) XXX_Size Uses

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal Uses

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

type Query Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Query is passed in a LookupRequest

func (*Query) Descriptor Uses

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

func (*Query) GetAddress Uses

func (m *Query) GetAddress() string

func (*Query) GetGateway Uses

func (m *Query) GetGateway() string

func (*Query) GetNetwork Uses

func (m *Query) GetNetwork() string

func (*Query) GetRouter Uses

func (m *Query) GetRouter() string

func (*Query) GetService Uses

func (m *Query) GetService() string

func (*Query) ProtoMessage Uses

func (*Query) ProtoMessage()

func (*Query) Reset Uses

func (m *Query) Reset()

func (*Query) String Uses

func (m *Query) String() string

func (*Query) XXX_DiscardUnknown Uses

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal Uses

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

func (*Query) XXX_Merge Uses

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

func (*Query) XXX_Size Uses

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal Uses

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

type RoutesRequest Uses

type RoutesRequest struct {
    // filter based on
    Query                *Query   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*RoutesRequest) Descriptor Uses

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

func (*RoutesRequest) GetQuery Uses

func (m *RoutesRequest) GetQuery() *Query

func (*RoutesRequest) ProtoMessage Uses

func (*RoutesRequest) ProtoMessage()

func (*RoutesRequest) Reset Uses

func (m *RoutesRequest) Reset()

func (*RoutesRequest) String Uses

func (m *RoutesRequest) String() string

func (*RoutesRequest) XXX_DiscardUnknown Uses

func (m *RoutesRequest) XXX_DiscardUnknown()

func (*RoutesRequest) XXX_Marshal Uses

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

func (*RoutesRequest) XXX_Merge Uses

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

func (*RoutesRequest) XXX_Size Uses

func (m *RoutesRequest) XXX_Size() int

func (*RoutesRequest) XXX_Unmarshal Uses

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

type RoutesResponse Uses

type RoutesResponse struct {
    Routes               []*proto1.Route `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

func (*RoutesResponse) Descriptor Uses

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

func (*RoutesResponse) GetRoutes Uses

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

func (*RoutesResponse) ProtoMessage Uses

func (*RoutesResponse) ProtoMessage()

func (*RoutesResponse) Reset Uses

func (m *RoutesResponse) Reset()

func (*RoutesResponse) String Uses

func (m *RoutesResponse) String() string

func (*RoutesResponse) XXX_DiscardUnknown Uses

func (m *RoutesResponse) XXX_DiscardUnknown()

func (*RoutesResponse) XXX_Marshal Uses

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

func (*RoutesResponse) XXX_Merge Uses

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

func (*RoutesResponse) XXX_Size Uses

func (m *RoutesResponse) XXX_Size() int

func (*RoutesResponse) XXX_Unmarshal Uses

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

type ServicesRequest Uses

type ServicesRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ServicesRequest) Descriptor Uses

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

func (*ServicesRequest) ProtoMessage Uses

func (*ServicesRequest) ProtoMessage()

func (*ServicesRequest) Reset Uses

func (m *ServicesRequest) Reset()

func (*ServicesRequest) String Uses

func (m *ServicesRequest) String() string

func (*ServicesRequest) XXX_DiscardUnknown Uses

func (m *ServicesRequest) XXX_DiscardUnknown()

func (*ServicesRequest) XXX_Marshal Uses

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

func (*ServicesRequest) XXX_Merge Uses

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

func (*ServicesRequest) XXX_Size Uses

func (m *ServicesRequest) XXX_Size() int

func (*ServicesRequest) XXX_Unmarshal Uses

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

type ServicesResponse Uses

type ServicesResponse struct {
    Services             []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ServicesResponse) Descriptor Uses

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

func (*ServicesResponse) GetServices Uses

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

func (*ServicesResponse) ProtoMessage Uses

func (*ServicesResponse) ProtoMessage()

func (*ServicesResponse) Reset Uses

func (m *ServicesResponse) Reset()

func (*ServicesResponse) String Uses

func (m *ServicesResponse) String() string

func (*ServicesResponse) XXX_DiscardUnknown Uses

func (m *ServicesResponse) XXX_DiscardUnknown()

func (*ServicesResponse) XXX_Marshal Uses

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

func (*ServicesResponse) XXX_Merge Uses

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

func (*ServicesResponse) XXX_Size Uses

func (m *ServicesResponse) XXX_Size() int

func (*ServicesResponse) XXX_Unmarshal Uses

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

type Status Uses

type Status struct {
    Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Status is node status

func (*Status) Descriptor Uses

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

func (*Status) GetError Uses

func (m *Status) GetError() *Error

func (*Status) ProtoMessage Uses

func (*Status) ProtoMessage()

func (*Status) Reset Uses

func (m *Status) Reset()

func (*Status) String Uses

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown Uses

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal Uses

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

func (*Status) XXX_Merge Uses

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

func (*Status) XXX_Size Uses

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal Uses

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

type StatusRequest Uses

type StatusRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*StatusRequest) Descriptor Uses

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

func (*StatusRequest) ProtoMessage Uses

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset Uses

func (m *StatusRequest) Reset()

func (*StatusRequest) String Uses

func (m *StatusRequest) String() string

func (*StatusRequest) XXX_DiscardUnknown Uses

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal Uses

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

func (*StatusRequest) XXX_Merge Uses

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

func (*StatusRequest) XXX_Size Uses

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal Uses

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

type StatusResponse Uses

type StatusResponse struct {
    Status               *Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*StatusResponse) Descriptor Uses

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

func (*StatusResponse) GetStatus Uses

func (m *StatusResponse) GetStatus() *Status

func (*StatusResponse) ProtoMessage Uses

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset Uses

func (m *StatusResponse) Reset()

func (*StatusResponse) String Uses

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown Uses

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal Uses

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

func (*StatusResponse) XXX_Merge Uses

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

func (*StatusResponse) XXX_Size Uses

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal Uses

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

type Sync Uses

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

Sync is network sync message

func (*Sync) Descriptor Uses

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

func (*Sync) GetPeer Uses

func (m *Sync) GetPeer() *Peer

func (*Sync) GetRoutes Uses

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

func (*Sync) ProtoMessage Uses

func (*Sync) ProtoMessage()

func (*Sync) Reset Uses

func (m *Sync) Reset()

func (*Sync) String Uses

func (m *Sync) String() string

func (*Sync) XXX_DiscardUnknown Uses

func (m *Sync) XXX_DiscardUnknown()

func (*Sync) XXX_Marshal Uses

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

func (*Sync) XXX_Merge Uses

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

func (*Sync) XXX_Size Uses

func (m *Sync) XXX_Size() int

func (*Sync) XXX_Unmarshal Uses

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

Package go_micro_network imports 7 packages (graph) and is imported by 7 packages. Updated 2020-02-22. Refresh now. Tools for package owners.