server

Jan 22, 2021

Changes in this version

+ func NewRegistryOpenAPI() *registry.OpenAPI

Jan 19, 2021

Changes in this version

+ var ErrIntOverflowServer = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthServer = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupServer = fmt.Errorf("proto: unexpected end of group")

+ 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

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

+ func (*EmptyResponse) ProtoMessage()

+ func (m *EmptyResponse) Marshal() (dAtA []byte, err error)

+ func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EmptyResponse) Reset()

+ func (m *EmptyResponse) Size() (n int)

+ func (m *EmptyResponse) String() string

+ func (m *EmptyResponse) Unmarshal(dAtA []byte) error

+ 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 GetRequest struct

+ Service string

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

+ func (*GetRequest) ProtoMessage()

+ func (m *GetRequest) GetService() string

+ func (m *GetRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetRequest) Reset()

+ func (m *GetRequest) Size() (n int)

+ func (m *GetRequest) String() string

+ func (m *GetRequest) Unmarshal(dAtA []byte) error

+ 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 []*registry.Service

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

+ func (*GetResponse) ProtoMessage()

+ func (m *GetResponse) GetServices() []*registry.Service

+ func (m *GetResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetResponse) Reset()

+ func (m *GetResponse) Size() (n int)

+ func (m *GetResponse) String() string

+ func (m *GetResponse) Unmarshal(dAtA []byte) error

+ 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

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

+ func (*ListRequest) ProtoMessage()

+ func (m *ListRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ListRequest) Reset()

+ func (m *ListRequest) Size() (n int)

+ func (m *ListRequest) String() string

+ func (m *ListRequest) Unmarshal(dAtA []byte) error

+ 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 []*registry.Service

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

+ func (*ListResponse) ProtoMessage()

+ func (m *ListResponse) GetServices() []*registry.Service

+ func (m *ListResponse) Marshal() (dAtA []byte, err error)

+ func (m *ListResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ListResponse) Reset()

+ func (m *ListResponse) Size() (n int)

+ func (m *ListResponse) String() string

+ func (m *ListResponse) Unmarshal(dAtA []byte) error

+ 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 OpenAPIRequest struct

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

+ func (*OpenAPIRequest) ProtoMessage()

+ func (m *OpenAPIRequest) Marshal() (dAtA []byte, err error)

+ func (m *OpenAPIRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *OpenAPIRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OpenAPIRequest) Reset()

+ func (m *OpenAPIRequest) Size() (n int)

+ func (m *OpenAPIRequest) String() string

+ func (m *OpenAPIRequest) Unmarshal(dAtA []byte) error

+ func (m *OpenAPIRequest) XXX_DiscardUnknown()

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

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

+ func (m *OpenAPIRequest) XXX_Size() int

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

+ type OpenAPIResponse struct

+ OpenAPI *registry.OpenAPI

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

+ func (*OpenAPIResponse) ProtoMessage()

+ func (m *OpenAPIResponse) GetOpenAPI() *registry.OpenAPI

+ func (m *OpenAPIResponse) Marshal() (dAtA []byte, err error)

+ func (m *OpenAPIResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *OpenAPIResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OpenAPIResponse) Reset()

+ func (m *OpenAPIResponse) Size() (n int)

+ func (m *OpenAPIResponse) String() string

+ func (m *OpenAPIResponse) Unmarshal(dAtA []byte) error

+ func (m *OpenAPIResponse) XXX_DiscardUnknown()

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

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

+ func (m *OpenAPIResponse) XXX_Size() int

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

+ type RegistryClient interface

+ Deregister func(ctx context.Context, in *registry.Service, opts ...grpc.CallOption) (*EmptyResponse, error)

+ GetOpenAPI func(ctx context.Context, in *OpenAPIRequest, opts ...grpc.CallOption) (*OpenAPIResponse, 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 *registry.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, *registry.Service, *EmptyResponse) error

+ GetOpenAPI func(context.Context, *OpenAPIRequest, *OpenAPIResponse) error

+ GetService func(context.Context, *GetRequest, *GetResponse) error

+ ListServices func(context.Context, *ListRequest, *ListResponse) error

+ Register func(context.Context, *registry.Service, *EmptyResponse) error

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

+ type RegistryServer interface

+ Deregister func(context.Context, *registry.Service) (*EmptyResponse, error)

+ GetOpenAPI func(context.Context, *OpenAPIRequest) (*OpenAPIResponse, error)

+ GetService func(context.Context, *GetRequest) (*GetResponse, error)

+ ListServices func(context.Context, *ListRequest) (*ListResponse, error)

+ Register func(context.Context, *registry.Service) (*EmptyResponse, error)

+ Watch func(*WatchRequest, Registry_WatchServer) error

+ type RegistryService interface

+ Deregister func(ctx context.Context, in *registry.Service, opts ...client.CallOption) (*EmptyResponse, error)

+ GetOpenAPI func(ctx context.Context, in *OpenAPIRequest, opts ...client.CallOption) (*OpenAPIResponse, 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 *registry.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() (*registry.Result, error)

+ type Registry_WatchServer interface

+ Send func(*registry.Result) error

+ type Registry_WatchService interface

+ Close func() error

+ Context func() context.Context

+ Recv func() (*registry.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(*registry.Result) error

+ SendMsg func(interface{}) error

+ type UnimplementedRegistryServer struct

+ func (*UnimplementedRegistryServer) Deregister(ctx context.Context, req *registry.Service) (*EmptyResponse, error)

+ func (*UnimplementedRegistryServer) GetOpenAPI(ctx context.Context, req *OpenAPIRequest) (*OpenAPIResponse, 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 *registry.Service) (*EmptyResponse, error)

+ func (*UnimplementedRegistryServer) Watch(req *WatchRequest, srv Registry_WatchServer) error

+ type WatchRequest struct

+ Service string

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

+ func (*WatchRequest) ProtoMessage()

+ func (m *WatchRequest) GetService() string

+ func (m *WatchRequest) Marshal() (dAtA []byte, err error)

+ func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchRequest) Reset()

+ func (m *WatchRequest) Size() (n int)

+ func (m *WatchRequest) String() string

+ func (m *WatchRequest) Unmarshal(dAtA []byte) error

+ 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