Versions in this module Expand all Collapse all v2 v2.1.2 Apr 12, 2023 Changes in this version + var EventType_name = map[int32]string + var EventType_value = map[string]int32 + func NewRegistryEndpoints() []*api.Endpoint + func RegisterRegistryHandler(s server.Server, hdlr RegistryHandler, opts ...server.HandlerOption) error + func RegisterRegistryServer(s *grpc.Server, srv RegistryServer) + type EmptyResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EmptyResponse) Descriptor() ([]byte, []int) + func (*EmptyResponse) ProtoMessage() + func (m *EmptyResponse) Reset() + func (m *EmptyResponse) String() string + func (m *EmptyResponse) XXX_DiscardUnknown() + func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EmptyResponse) XXX_Merge(src proto.Message) + func (m *EmptyResponse) XXX_Size() int + func (m *EmptyResponse) XXX_Unmarshal(b []byte) error + type Endpoint struct + Metadata map[string]string + Name string + Request *Value + Response *Value + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Endpoint) Descriptor() ([]byte, []int) + func (*Endpoint) ProtoMessage() + func (m *Endpoint) GetMetadata() map[string]string + func (m *Endpoint) GetName() string + func (m *Endpoint) GetRequest() *Value + func (m *Endpoint) GetResponse() *Value + func (m *Endpoint) Reset() + func (m *Endpoint) String() string + func (m *Endpoint) XXX_DiscardUnknown() + func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Endpoint) XXX_Merge(src proto.Message) + func (m *Endpoint) XXX_Size() int + func (m *Endpoint) XXX_Unmarshal(b []byte) error + type Event struct + Id string + Service *Service + 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) GetService() *Service + 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 GetRequest struct + Service string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) GetService() string + func (m *GetRequest) Reset() + func (m *GetRequest) String() string + func (m *GetRequest) XXX_DiscardUnknown() + func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetRequest) XXX_Merge(src proto.Message) + func (m *GetRequest) XXX_Size() int + func (m *GetRequest) XXX_Unmarshal(b []byte) error + type GetResponse struct + Services []*Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) GetServices() []*Service + func (m *GetResponse) Reset() + func (m *GetResponse) String() string + func (m *GetResponse) XXX_DiscardUnknown() + func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResponse) XXX_Merge(src proto.Message) + func (m *GetResponse) XXX_Size() int + func (m *GetResponse) XXX_Unmarshal(b []byte) error + type ListRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) Reset() + func (m *ListRequest) String() string + func (m *ListRequest) XXX_DiscardUnknown() + func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListRequest) XXX_Merge(src proto.Message) + func (m *ListRequest) XXX_Size() int + func (m *ListRequest) XXX_Unmarshal(b []byte) error + type ListResponse struct + Services []*Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (m *ListResponse) GetServices() []*Service + func (m *ListResponse) Reset() + func (m *ListResponse) String() string + func (m *ListResponse) XXX_DiscardUnknown() + func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResponse) XXX_Merge(src proto.Message) + func (m *ListResponse) XXX_Size() int + func (m *ListResponse) XXX_Unmarshal(b []byte) error + type Node struct + Address string + Id string + Metadata map[string]string + Port int64 + 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) GetPort() int64 + 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 Options struct + Ttl int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Options) Descriptor() ([]byte, []int) + func (*Options) ProtoMessage() + func (m *Options) GetTtl() int64 + func (m *Options) Reset() + func (m *Options) String() string + func (m *Options) XXX_DiscardUnknown() + func (m *Options) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Options) XXX_Merge(src proto.Message) + func (m *Options) XXX_Size() int + func (m *Options) XXX_Unmarshal(b []byte) error + type RegistryClient interface + Deregister func(ctx context.Context, in *Service, opts ...grpc.CallOption) (*EmptyResponse, error) + GetService func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + ListServices func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) + Register func(ctx context.Context, in *Service, opts ...grpc.CallOption) (*EmptyResponse, error) + Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Registry_WatchClient, error) + func NewRegistryClient(cc *grpc.ClientConn) RegistryClient + type RegistryHandler interface + Deregister func(context.Context, *Service, *EmptyResponse) error + GetService func(context.Context, *GetRequest, *GetResponse) error + ListServices func(context.Context, *ListRequest, *ListResponse) error + Register func(context.Context, *Service, *EmptyResponse) error + Watch func(context.Context, *WatchRequest, Registry_WatchStream) error + type RegistryServer interface + Deregister func(context.Context, *Service) (*EmptyResponse, error) + GetService func(context.Context, *GetRequest) (*GetResponse, error) + ListServices func(context.Context, *ListRequest) (*ListResponse, error) + Register func(context.Context, *Service) (*EmptyResponse, error) + Watch func(*WatchRequest, Registry_WatchServer) error + type RegistryService interface + Deregister func(ctx context.Context, in *Service, opts ...client.CallOption) (*EmptyResponse, error) + GetService func(ctx context.Context, in *GetRequest, opts ...client.CallOption) (*GetResponse, error) + ListServices func(ctx context.Context, in *ListRequest, opts ...client.CallOption) (*ListResponse, error) + Register func(ctx context.Context, in *Service, opts ...client.CallOption) (*EmptyResponse, error) + Watch func(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Registry_WatchService, error) + func NewRegistryService(name string, c client.Client) RegistryService + type Registry_WatchClient interface + Recv func() (*Result, error) + type Registry_WatchServer interface + Send func(*Result) error + type Registry_WatchService interface + Close func() error + Context func() context.Context + Recv func() (*Result, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Registry_WatchStream interface + Close func() error + Context func() context.Context + RecvMsg func(interface{}) error + Send func(*Result) error + SendMsg func(interface{}) error + type Result struct + Action string + Service *Service + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (m *Result) GetAction() string + func (m *Result) GetService() *Service + func (m *Result) GetTimestamp() int64 + func (m *Result) Reset() + func (m *Result) String() string + func (m *Result) XXX_DiscardUnknown() + func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Result) XXX_Merge(src proto.Message) + func (m *Result) XXX_Size() int + func (m *Result) XXX_Unmarshal(b []byte) error + type Service struct + Endpoints []*Endpoint + Metadata map[string]string + Name string + Nodes []*Node + Options *Options + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (m *Service) GetEndpoints() []*Endpoint + func (m *Service) GetMetadata() map[string]string + func (m *Service) GetName() string + func (m *Service) GetNodes() []*Node + func (m *Service) GetOptions() *Options + func (m *Service) GetVersion() string + func (m *Service) Reset() + func (m *Service) String() string + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Merge(src proto.Message) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + type UnimplementedRegistryServer struct + func (*UnimplementedRegistryServer) Deregister(ctx context.Context, req *Service) (*EmptyResponse, error) + func (*UnimplementedRegistryServer) GetService(ctx context.Context, req *GetRequest) (*GetResponse, error) + func (*UnimplementedRegistryServer) ListServices(ctx context.Context, req *ListRequest) (*ListResponse, error) + func (*UnimplementedRegistryServer) Register(ctx context.Context, req *Service) (*EmptyResponse, error) + func (*UnimplementedRegistryServer) Watch(req *WatchRequest, srv Registry_WatchServer) error + type Value struct + Name string + Type string + Values []*Value + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Value) Descriptor() ([]byte, []int) + func (*Value) ProtoMessage() + func (m *Value) GetName() string + func (m *Value) GetType() string + func (m *Value) GetValues() []*Value + func (m *Value) Reset() + func (m *Value) String() string + func (m *Value) XXX_DiscardUnknown() + func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Value) XXX_Merge(src proto.Message) + func (m *Value) XXX_Size() int + func (m *Value) XXX_Unmarshal(b []byte) error + type WatchRequest struct + Service string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + func (m *WatchRequest) GetService() string + 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
Go to main page