Documentation
¶
Index ¶
- Variables
- func NewApiEndpoints() []*api.Endpoint
- func RegisterApiHandler(s server.Server, hdlr ApiHandler, opts ...server.HandlerOption) error
- func RegisterApiServer(s *grpc.Server, srv ApiServer)
- type ApiClient
- type ApiHandler
- type ApiServer
- type ApiService
- type EmptyResponse
- type Endpoint
- func (*Endpoint) Descriptor() ([]byte, []int)deprecated
- func (x *Endpoint) GetHost() []string
- func (x *Endpoint) GetMethod() []string
- func (x *Endpoint) GetName() string
- func (x *Endpoint) GetPath() []string
- func (x *Endpoint) GetStream() bool
- func (*Endpoint) ProtoMessage()
- func (x *Endpoint) ProtoReflect() protoreflect.Message
- func (x *Endpoint) Reset()
- func (x *Endpoint) String() string
- type UnimplementedApiServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_api_service_proto_api_proto protoreflect.FileDescriptor
Functions ¶
func NewApiEndpoints ¶
func RegisterApiHandler ¶
func RegisterApiHandler(s server.Server, hdlr ApiHandler, opts ...server.HandlerOption) error
func RegisterApiServer ¶
Types ¶
type ApiClient ¶
type ApiClient interface {
Register(ctx context.Context, in *Endpoint, opts ...grpc.CallOption) (*EmptyResponse, error)
Deregister(ctx context.Context, in *Endpoint, opts ...grpc.CallOption) (*EmptyResponse, error)
}
ApiClient is the client API for Api service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewApiClient ¶
func NewApiClient(cc grpc.ClientConnInterface) ApiClient
type ApiHandler ¶
type ApiHandler interface {
Register(context.Context, *Endpoint, *EmptyResponse) error
Deregister(context.Context, *Endpoint, *EmptyResponse) error
}
type ApiServer ¶
type ApiServer interface {
Register(context.Context, *Endpoint) (*EmptyResponse, error)
Deregister(context.Context, *Endpoint) (*EmptyResponse, error)
}
ApiServer is the server API for Api service.
type ApiService ¶
type ApiService interface {
Register(ctx context.Context, in *Endpoint, opts ...client.CallOption) (*EmptyResponse, error)
Deregister(ctx context.Context, in *Endpoint, opts ...client.CallOption) (*EmptyResponse, error)
}
func NewApiService ¶
func NewApiService(name string, c client.Client) ApiService
type EmptyResponse ¶
type EmptyResponse struct {
// contains filtered or unexported fields
}
func (*EmptyResponse) Descriptor
deprecated
func (*EmptyResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) ProtoReflect ¶
func (x *EmptyResponse) ProtoReflect() protoreflect.Message
func (*EmptyResponse) Reset ¶
func (x *EmptyResponse) Reset()
func (*EmptyResponse) String ¶
func (x *EmptyResponse) String() string
type Endpoint ¶
type Endpoint struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Host []string `protobuf:"bytes,2,rep,name=host,proto3" json:"host,omitempty"`
Path []string `protobuf:"bytes,3,rep,name=path,proto3" json:"path,omitempty"`
Method []string `protobuf:"bytes,4,rep,name=method,proto3" json:"method,omitempty"`
Stream bool `protobuf:"varint,5,opt,name=stream,proto3" json:"stream,omitempty"`
// contains filtered or unexported fields
}
func (*Endpoint) Descriptor
deprecated
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) ProtoReflect ¶
func (x *Endpoint) ProtoReflect() protoreflect.Message
type UnimplementedApiServer ¶
type UnimplementedApiServer struct {
}
UnimplementedApiServer can be embedded to have forward compatible implementations.
func (*UnimplementedApiServer) Deregister ¶
func (*UnimplementedApiServer) Deregister(context.Context, *Endpoint) (*EmptyResponse, error)
func (*UnimplementedApiServer) Register ¶
func (*UnimplementedApiServer) Register(context.Context, *Endpoint) (*EmptyResponse, error)
Click to show internal directories.
Click to hide internal directories.