go_micro_api

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
  • func NewApiClient(cc grpc.ClientConnInterface) ApiClient
• type ApiHandler
• type ApiServer
• type ApiService
  • func NewApiService(name string, c client.Client) ApiService
• type EmptyResponse
  • func (*EmptyResponse) Descriptor() ([]byte, []int)
  • func (*EmptyResponse) ProtoMessage()
  • func (x *EmptyResponse) ProtoReflect() protoreflect.Message
  • func (x *EmptyResponse) Reset()
  • func (x *EmptyResponse) String() string
• type Endpoint
  • func (*Endpoint) Descriptor() ([]byte, []int)
  • 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
  • func (*UnimplementedApiServer) Deregister(context.Context, *Endpoint) (*EmptyResponse, error)
  • func (*UnimplementedApiServer) Register(context.Context, *Endpoint) (*EmptyResponse, error)

Variables

var File_api_service_proto_api_proto protoreflect.FileDescriptor

Functions

func NewApiEndpoints

func NewApiEndpoints() []*api.Endpoint

func RegisterApiHandler

func RegisterApiHandler(s server.Server, hdlr ApiHandler, opts ...server.HandlerOption) error

func RegisterApiServer

func RegisterApiServer(s *grpc.Server, srv ApiServer)

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

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

func (*Endpoint) Descriptor() ([]byte, []int)

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetHost

func (x *Endpoint) GetHost() []string

func (*Endpoint) GetMethod

func (x *Endpoint) GetMethod() []string

func (*Endpoint) GetName

func (x *Endpoint) GetName() string

func (*Endpoint) GetPath

func (x *Endpoint) GetPath() []string

func (*Endpoint) GetStream

func (x *Endpoint) GetStream() bool

func (*Endpoint) ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect

func (x *Endpoint) ProtoReflect() protoreflect.Message

func (*Endpoint) Reset

func (x *Endpoint) Reset()

func (*Endpoint) String

func (x *Endpoint) String() string

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)