router

package

Go to main page

Versions in this module

v3

v3.9.0

Sep 13, 2022

v3.8.9

Sep 9, 2022

v3.8.8

Aug 31, 2022

v3.8.7

Jun 13, 2022

v3.8.6

Apr 1, 2022

v3.8.5

Feb 18, 2022

v3.8.4

Feb 10, 2022

v3.8.3

Jan 13, 2022

Changes in this version

+ var File_proto_router_router_proto protoreflect.FileDescriptor

type CreateResponse

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

type DeleteResponse

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

type Event

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

type EventType

+ func (EventType) Descriptor() protoreflect.EnumDescriptor

+ func (EventType) Type() protoreflect.EnumType

+ func (x EventType) Enum() *EventType

+ func (x EventType) Number() protoreflect.EnumNumber

type LookupOptions

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

type LookupRequest

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

type LookupResponse

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

type ReadRequest

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

type ReadResponse

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

type Route

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

+ type UnimplementedRouterServer struct

+ func (*UnimplementedRouterServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error)

+ func (*UnimplementedRouterServer) Watch(*WatchRequest, Router_WatchServer) error

+ type UnimplementedTableServer struct

+ func (*UnimplementedTableServer) Create(context.Context, *Route) (*CreateResponse, error)

+ func (*UnimplementedTableServer) Delete(context.Context, *Route) (*DeleteResponse, error)

+ func (*UnimplementedTableServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

+ func (*UnimplementedTableServer) Update(context.Context, *Route) (*UpdateResponse, error)

type UpdateResponse

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

type WatchRequest

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

v3.8.2

Dec 15, 2021

v3.8.1

Dec 15, 2021

Changes in this version

+ var EventType_name = map[int32]string

+ var EventType_value = map[string]int32

+ func NewRouterEndpoints() []*api.Endpoint

+ func NewTableEndpoints() []*api.Endpoint

+ func RegisterRouterHandler(s server.Server, hdlr RouterHandler, opts ...server.HandlerOption) error

+ func RegisterRouterServer(s *grpc.Server, srv RouterServer)

+ func RegisterTableHandler(s server.Server, hdlr TableHandler, opts ...server.HandlerOption) error

+ func RegisterTableServer(s *grpc.Server, srv TableServer)

+ type CreateResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateResponse) ProtoMessage()

+ func (m *CreateResponse) Reset()

+ func (m *CreateResponse) String() string

+ func (m *CreateResponse) XXX_DiscardUnknown()

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

+ func (m *CreateResponse) XXX_Merge(src proto.Message)

+ func (m *CreateResponse) XXX_Size() int

+ func (m *CreateResponse) XXX_Unmarshal(b []byte) error

+ type DeleteResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteResponse) ProtoMessage()

+ func (m *DeleteResponse) Reset()

+ func (m *DeleteResponse) String() string

+ func (m *DeleteResponse) XXX_DiscardUnknown()

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

+ func (m *DeleteResponse) XXX_Merge(src proto.Message)

+ func (m *DeleteResponse) XXX_Size() int

+ func (m *DeleteResponse) XXX_Unmarshal(b []byte) error

+ type Event struct

+ Id string

+ Route *Route

+ Timestamp int64

+ Type EventType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Event) ProtoMessage()

+ func (m *Event) GetId() string

+ func (m *Event) GetRoute() *Route

+ func (m *Event) GetTimestamp() int64

+ func (m *Event) GetType() EventType

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ func (m *Event) XXX_DiscardUnknown()

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

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

+ func (m *Event) XXX_Size() int

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

+ type EventType int32

+ const EventType_Create

+ const EventType_Delete

+ const EventType_Update

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

+ func (x EventType) String() string

+ type LookupOptions struct

+ Address string

+ Gateway string

+ Link string

+ Network string

+ Router string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LookupOptions) ProtoMessage()

+ func (m *LookupOptions) GetAddress() string

+ func (m *LookupOptions) GetGateway() string

+ func (m *LookupOptions) GetLink() string

+ func (m *LookupOptions) GetNetwork() string

+ func (m *LookupOptions) GetRouter() string

+ func (m *LookupOptions) Reset()

+ func (m *LookupOptions) String() string

+ func (m *LookupOptions) XXX_DiscardUnknown()

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

+ func (m *LookupOptions) XXX_Merge(src proto.Message)

+ func (m *LookupOptions) XXX_Size() int

+ func (m *LookupOptions) XXX_Unmarshal(b []byte) error

+ type LookupRequest struct

+ Options *LookupOptions

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LookupRequest) ProtoMessage()

+ func (m *LookupRequest) GetOptions() *LookupOptions

+ func (m *LookupRequest) GetService() string

+ func (m *LookupRequest) Reset()

+ func (m *LookupRequest) String() string

+ func (m *LookupRequest) XXX_DiscardUnknown()

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

+ func (m *LookupRequest) XXX_Merge(src proto.Message)

+ func (m *LookupRequest) XXX_Size() int

+ func (m *LookupRequest) XXX_Unmarshal(b []byte) error

+ type LookupResponse struct

+ Routes []*Route

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LookupResponse) ProtoMessage()

+ func (m *LookupResponse) GetRoutes() []*Route

+ func (m *LookupResponse) Reset()

+ func (m *LookupResponse) String() string

+ func (m *LookupResponse) XXX_DiscardUnknown()

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

+ func (m *LookupResponse) XXX_Merge(src proto.Message)

+ func (m *LookupResponse) XXX_Size() int

+ func (m *LookupResponse) XXX_Unmarshal(b []byte) error

+ type ReadRequest struct

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadRequest) ProtoMessage()

+ func (m *ReadRequest) GetService() string

+ func (m *ReadRequest) Reset()

+ func (m *ReadRequest) String() string

+ func (m *ReadRequest) XXX_DiscardUnknown()

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

+ func (m *ReadRequest) XXX_Merge(src proto.Message)

+ func (m *ReadRequest) XXX_Size() int

+ func (m *ReadRequest) XXX_Unmarshal(b []byte) error

+ type ReadResponse struct

+ Routes []*Route

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadResponse) ProtoMessage()

+ func (m *ReadResponse) GetRoutes() []*Route

+ func (m *ReadResponse) Reset()

+ func (m *ReadResponse) String() string

+ func (m *ReadResponse) XXX_DiscardUnknown()

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

+ func (m *ReadResponse) XXX_Merge(src proto.Message)

+ func (m *ReadResponse) XXX_Size() int

+ func (m *ReadResponse) XXX_Unmarshal(b []byte) error

+ type Route struct

+ Address string

+ Gateway string

+ Link string

+ Metadata map[string]string

+ Metric int64

+ Network string

+ Router string

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Route) ProtoMessage()

+ func (m *Route) GetAddress() string

+ func (m *Route) GetGateway() string

+ func (m *Route) GetLink() string

+ func (m *Route) GetMetadata() map[string]string

+ func (m *Route) GetMetric() int64

+ func (m *Route) GetNetwork() string

+ func (m *Route) GetRouter() string

+ func (m *Route) GetService() string

+ func (m *Route) Reset()

+ func (m *Route) String() string

+ func (m *Route) XXX_DiscardUnknown()

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

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

+ func (m *Route) XXX_Size() int

+ func (m *Route) XXX_Unmarshal(b []byte) error

+ type RouterClient interface

+ Lookup func(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)

+ Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Router_WatchClient, error)

+ func NewRouterClient(cc *grpc.ClientConn) RouterClient

+ type RouterHandler interface

+ Lookup func(context.Context, *LookupRequest, *LookupResponse) error

+ Watch func(context.Context, *WatchRequest, Router_WatchStream) error

+ type RouterServer interface

+ Lookup func(context.Context, *LookupRequest) (*LookupResponse, error)

+ Watch func(*WatchRequest, Router_WatchServer) error

+ type RouterService interface

+ Lookup func(ctx context.Context, in *LookupRequest, opts ...client.CallOption) (*LookupResponse, error)

+ Watch func(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Router_WatchService, error)

+ func NewRouterService(name string, c client.Client) RouterService

+ type Router_WatchClient interface

+ Recv func() (*Event, error)

+ type Router_WatchServer interface

+ Send func(*Event) error

+ type Router_WatchService interface

+ Close func() error

+ Context func() context.Context

+ Recv func() (*Event, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type Router_WatchStream interface

+ Close func() error

+ Context func() context.Context

+ RecvMsg func(interface{}) error

+ Send func(*Event) error

+ SendMsg func(interface{}) error

+ type TableClient interface

+ Create func(ctx context.Context, in *Route, opts ...grpc.CallOption) (*CreateResponse, error)

+ Delete func(ctx context.Context, in *Route, opts ...grpc.CallOption) (*DeleteResponse, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)

+ Update func(ctx context.Context, in *Route, opts ...grpc.CallOption) (*UpdateResponse, error)

+ func NewTableClient(cc *grpc.ClientConn) TableClient

+ type TableHandler interface

+ Create func(context.Context, *Route, *CreateResponse) error

+ Delete func(context.Context, *Route, *DeleteResponse) error

+ Read func(context.Context, *ReadRequest, *ReadResponse) error

+ Update func(context.Context, *Route, *UpdateResponse) error

+ type TableServer interface

+ Create func(context.Context, *Route) (*CreateResponse, error)

+ Delete func(context.Context, *Route) (*DeleteResponse, error)

+ Read func(context.Context, *ReadRequest) (*ReadResponse, error)

+ Update func(context.Context, *Route) (*UpdateResponse, error)

+ type TableService interface

+ Create func(ctx context.Context, in *Route, opts ...client.CallOption) (*CreateResponse, error)

+ Delete func(ctx context.Context, in *Route, opts ...client.CallOption) (*DeleteResponse, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)

+ Update func(ctx context.Context, in *Route, opts ...client.CallOption) (*UpdateResponse, error)

+ func NewTableService(name string, c client.Client) TableService

+ type UpdateResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateResponse) ProtoMessage()

+ func (m *UpdateResponse) Reset()

+ func (m *UpdateResponse) String() string

+ func (m *UpdateResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateResponse) XXX_Merge(src proto.Message)

+ func (m *UpdateResponse) XXX_Size() int

+ func (m *UpdateResponse) XXX_Unmarshal(b []byte) error

+ type WatchRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WatchRequest) ProtoMessage()

+ func (m *WatchRequest) Reset()

+ func (m *WatchRequest) String() string

+ func (m *WatchRequest) XXX_DiscardUnknown()

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

+ func (m *WatchRequest) XXX_Merge(src proto.Message)

+ func (m *WatchRequest) XXX_Size() int

+ func (m *WatchRequest) XXX_Unmarshal(b []byte) error

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