proto

package

Go to main page

Versions in this module

v2

v2.9.9

Mar 31, 2022

v2.9.8

Mar 31, 2022

Changes in this version

+ var File_registry_service_proto_registry_proto protoreflect.FileDescriptor

type EmptyResponse

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

type Endpoint

+ func (x *Endpoint) 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 GetRequest

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

type GetResponse

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

type ListRequest

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

type ListResponse

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

type Node

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

type Options

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

type Result

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

type Service

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

type Value

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

type WatchRequest

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

v2.9.7

Nov 30, 2021

v2.9.6

Aug 19, 2021

v2.9.5

Aug 11, 2021

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

v2.9.4

Aug 10, 2021

v2.9.3

Aug 10, 2021

v2.9.2

Aug 10, 2021

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