go_micro_network

package
v0.0.0-...-bd012e7 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AdvertType_name = map[int32]string{
	0: "AdvertAnnounce",
	1: "AdvertUpdate",
}
View Source 
var AdvertType_value = map[string]int32{
	"AdvertAnnounce": 0,
	"AdvertUpdate":   1,
}
View Source 
var EventType_name = map[int32]string{
	0: "Create",
	1: "Delete",
	2: "Update",
}
View Source 
var EventType_value = map[string]int32{
	"Create": 0,
	"Delete": 1,
	"Update": 2,
}

Functions

This section is empty.

Types 

type Advert struct {
	// id of the advertising router
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// type of advertisement
	Type AdvertType `protobuf:"varint,2,opt,name=type,proto3,enum=go.micro.network.AdvertType" json:"type,omitempty"`
	// unix timestamp of the advertisement
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// TTL of the Advert
	Ttl int64 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// events is a list of advertised events
	Events               []*Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Advert is router advertsement streamed by Watch

func (*Advert) Descriptor 

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

func (*Advert) GetEvents 

func (m *Advert) GetEvents() []*Event

func (*Advert) GetId 

func (m *Advert) GetId() string

func (*Advert) GetTimestamp 

func (m *Advert) GetTimestamp() int64

func (*Advert) GetTtl 

func (m *Advert) GetTtl() int64

func (*Advert) GetType 

func (m *Advert) GetType() AdvertType

func (*Advert) ProtoMessage 

func (*Advert) ProtoMessage()

func (*Advert) Reset 

func (m *Advert) Reset()

func (*Advert) String 

func (m *Advert) String() string

func (*Advert) XXX_DiscardUnknown 

func (m *Advert) XXX_DiscardUnknown()

func (*Advert) XXX_Marshal 

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

func (*Advert) XXX_Merge 

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

func (*Advert) XXX_Size 

func (m *Advert) XXX_Size() int

func (*Advert) XXX_Unmarshal 

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

type AdvertType 

type AdvertType int32

AdvertType defines the type of advert 

const (
	AdvertType_AdvertAnnounce AdvertType = 0
	AdvertType_AdvertUpdate   AdvertType = 1
)

func (AdvertType) EnumDescriptor 

func (AdvertType) EnumDescriptor() ([]byte, []int)

func (AdvertType) String 

func (x AdvertType) String() string

type Close 

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 

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

func (*Close) GetNode 

func (m *Close) GetNode() *Node

func (*Close) ProtoMessage 

func (*Close) ProtoMessage()

func (*Close) Reset 

func (m *Close) Reset()

func (*Close) String 

func (m *Close) String() string

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"`
	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 

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

func (*Connect) GetNode 

func (m *Connect) GetNode() *Node

func (*Connect) ProtoMessage 

func (*Connect) ProtoMessage()

func (*Connect) Reset 

func (m *Connect) Reset()

func (*Connect) String 

func (m *Connect) String() string

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

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) GetNodes 

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

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

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

func (*ConnectResponse) Descriptor 

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

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset 

func (m *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (m *ConnectResponse) String() string

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

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

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

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 Event 

type Event struct {
	// the unique event id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// type of event
	Type EventType `protobuf:"varint,2,opt,name=type,proto3,enum=go.micro.network.EventType" json:"type,omitempty"`
	// unix timestamp of event
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// service route
	Route                *Route   `protobuf:"bytes,4,opt,name=route,proto3" json:"route,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Event is routing table event

func (*Event) Descriptor 

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

func (*Event) GetId 

func (m *Event) GetId() string

func (*Event) GetRoute 

func (m *Event) GetRoute() *Route

func (*Event) GetTimestamp 

func (m *Event) GetTimestamp() int64

func (*Event) GetType 

func (m *Event) GetType() EventType

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventType 

type EventType int32

EventType defines the type of event 

const (
	EventType_Create EventType = 0
	EventType_Delete EventType = 1
	EventType_Update EventType = 2
)

func (EventType) EnumDescriptor 

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String 

func (x EventType) String() string

type GraphRequest 

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 

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

func (*GraphRequest) GetDepth 

func (m *GraphRequest) GetDepth() uint32

func (*GraphRequest) ProtoMessage 

func (*GraphRequest) ProtoMessage()

func (*GraphRequest) Reset 

func (m *GraphRequest) Reset()

func (*GraphRequest) String 

func (m *GraphRequest) String() string

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

func (*GraphResponse) Descriptor 

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

func (*GraphResponse) GetRoot 

func (m *GraphResponse) GetRoot() *Peer

func (*GraphResponse) ProtoMessage 

func (*GraphResponse) ProtoMessage()

func (*GraphResponse) Reset 

func (m *GraphResponse) Reset()

func (*GraphResponse) String 

func (m *GraphResponse) String() string

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

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

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

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

PeerRequest requests list of peers

func (*NodesRequest) Descriptor 

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

func (*NodesRequest) GetDepth 

func (m *NodesRequest) GetDepth() uint32

func (*NodesRequest) ProtoMessage 

func (*NodesRequest) ProtoMessage()

func (*NodesRequest) Reset 

func (m *NodesRequest) Reset()

func (*NodesRequest) String 

func (m *NodesRequest) String() string

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

PeerResponse is returned by ListPeers

func (*NodesResponse) Descriptor 

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

func (*NodesResponse) GetNodes 

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

func (*NodesResponse) ProtoMessage 

func (*NodesResponse) ProtoMessage()

func (*NodesResponse) Reset 

func (m *NodesResponse) Reset()

func (*NodesResponse) String 

func (m *NodesResponse) String() string

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

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

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) String 

func (m *Peer) String() string

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

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

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

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 Route 

type Route struct {
	// service for the route
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// the address that advertise this route
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// gateway as the next hop
	Gateway string `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
	// the network for this destination
	Network string `protobuf:"bytes,4,opt,name=network,proto3" json:"network,omitempty"`
	// router if the router id
	Router string `protobuf:"bytes,5,opt,name=router,proto3" json:"router,omitempty"`
	// the network link
	Link string `protobuf:"bytes,6,opt,name=link,proto3" json:"link,omitempty"`
	// the metric / score of this route
	Metric               int64    `protobuf:"varint,7,opt,name=metric,proto3" json:"metric,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Route is a service route

func (*Route) Descriptor 

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

func (*Route) GetAddress 

func (m *Route) GetAddress() string

func (*Route) GetGateway 

func (m *Route) GetGateway() string
func (m *Route) GetLink() string

func (*Route) GetMetric 

func (m *Route) GetMetric() int64

func (*Route) GetNetwork 

func (m *Route) GetNetwork() string

func (*Route) GetRouter 

func (m *Route) GetRouter() string

func (*Route) GetService 

func (m *Route) GetService() string

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) Reset 

func (m *Route) Reset()

func (*Route) String 

func (m *Route) String() string

func (*Route) XXX_DiscardUnknown 

func (m *Route) XXX_DiscardUnknown()

func (*Route) XXX_Marshal 

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

func (*Route) XXX_Merge 

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

func (*Route) XXX_Size 

func (m *Route) XXX_Size() int

func (*Route) XXX_Unmarshal 

func (m *Route) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RoutesRequest) Descriptor 

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

func (*RoutesRequest) GetQuery 

func (m *RoutesRequest) GetQuery() *Query

func (*RoutesRequest) ProtoMessage 

func (*RoutesRequest) ProtoMessage()

func (*RoutesRequest) Reset 

func (m *RoutesRequest) Reset()

func (*RoutesRequest) String 

func (m *RoutesRequest) String() string

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               []*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 

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

func (*RoutesResponse) GetRoutes 

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

func (*RoutesResponse) ProtoMessage 

func (*RoutesResponse) ProtoMessage()

func (*RoutesResponse) Reset 

func (m *RoutesResponse) Reset()

func (*RoutesResponse) String 

func (m *RoutesResponse) String() string

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

func (*ServicesRequest) Descriptor 

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

func (*ServicesRequest) ProtoMessage 

func (*ServicesRequest) ProtoMessage()

func (*ServicesRequest) Reset 

func (m *ServicesRequest) Reset()

func (*ServicesRequest) String 

func (m *ServicesRequest) String() string

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

func (*ServicesResponse) Descriptor 

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

func (*ServicesResponse) GetServices 

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

func (*ServicesResponse) ProtoMessage 

func (*ServicesResponse) ProtoMessage()

func (*ServicesResponse) Reset 

func (m *ServicesResponse) Reset()

func (*ServicesResponse) String 

func (m *ServicesResponse) String() string

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

Status is node status

func (*Status) Descriptor 

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

func (*Status) GetError 

func (m *Status) GetError() *Error

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

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

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

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

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetStatus 

func (m *StatusResponse) GetStatus() *Status

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

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               []*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 

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

func (*Sync) GetPeer 

func (m *Sync) GetPeer() *Peer

func (*Sync) GetRoutes 

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

func (*Sync) ProtoMessage 

func (*Sync) ProtoMessage()

func (*Sync) Reset 

func (m *Sync) Reset()

func (*Sync) String 

func (m *Sync) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.