pb

type ExampleClient ¶

type ExampleClient interface {
	// 健康检查
	Hello(ctx context.Context, opts ...grpc.CallOption) (Example_HelloClient, error)
}

ExampleClient is the client API for Example service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExampleClient(cc grpc.ClientConnInterface) ExampleClient

type ExampleKitClient ¶

type ExampleKitClient interface {
}

ExampleKitClient is the go-kit client API for Example service.

func NewExampleKitClient(s ExampleKitEndpointSet) ExampleKitClient

type ExampleKitEndpointSet ¶

type ExampleKitEndpointSet struct {
}

ExampleKitEndpointSet is realize kit/endpoint.Endpoint

func NewExampleKitEndpointSet(srv ExampleKitServer, mws ...endpoint.Middleware) ExampleKitEndpointSet

type ExampleKitGRPCHandlerSet ¶

type ExampleKitGRPCHandlerSet struct {
	HelloHandler *grpc.Server
}

ExampleKitGRPCHandlerSet is realize kit/transport/grpc.Server set.

func NewExampleKitGRPCHandlerSet(
	set ExampleKitEndpointSet,
	transport ExampleKitGRPCTransport,
	opts ...grpc.ServerOption,
) ExampleKitGRPCHandlerSet

type ExampleKitGRPCTransport ¶

type ExampleKitGRPCTransport interface {
}

ExampleKitGRPCTransport defined from kit/transport/grpc.

type ExampleKitHTTPHandlerSet ¶

type ExampleKitHTTPHandlerSet struct {
	HelloHandler *http.Server
}

ExampleKitHTTPHandlerSet is realize kit/transport/http.Server set.

func NewExampleKitHTTPHandlerSet(
	set ExampleKitEndpointSet,
	transport ExampleKitHTTPTransport,
	opts ...http.ServerOption,
) ExampleKitHTTPHandlerSet

type ExampleKitHTTPTransport ¶

type ExampleKitHTTPTransport interface {
}

ExampleKitHTTPTransport defined from kit/transport/http.

type ExampleKitServer ¶

type ExampleKitServer interface {
	// contains filtered or unexported methods
}

ExampleKitServer is the server API for Example service. All implementations must embed UnimplementedExampleKitServer for forward compatibility

type ExampleServer ¶

type ExampleServer interface {
	// 健康检查
	Hello(Example_HelloServer) error
	// contains filtered or unexported methods
}

ExampleServer is the server API for Example service. All implementations must embed UnimplementedExampleServer for forward compatibility

type Example_HelloClient ¶

type Example_HelloClient interface {
	Send(*HelloRequest) error
	CloseAndRecv() (*HelloResponse, error)
	grpc.ClientStream
}

type Example_HelloServer ¶

type Example_HelloServer interface {
	SendAndClose(*HelloResponse) error
	Recv() (*HelloRequest, error)
	grpc.ServerStream
}

type GetDepartmentRequest ¶

type GetDepartmentRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *GetDepartmentRequest) GetId() string

func (*GetDepartmentRequest) ProtoMessage()

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

func (x *GetDepartmentRequest) Reset()

func (x *GetDepartmentRequest) String() string

type GetDepartmentResponse ¶

type GetDepartmentResponse struct {
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *GetDepartmentResponse) GetData() string

func (*GetDepartmentResponse) ProtoMessage()

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

func (x *GetDepartmentResponse) Reset()

func (x *GetDepartmentResponse) String() string

type HealthRequest ¶

type HealthRequest struct {
	// contains filtered or unexported fields
}

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

func (*HealthRequest) ProtoMessage()

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

func (x *HealthRequest) Reset()

func (x *HealthRequest) String() string

type HealthResponse ¶

type HealthResponse struct {
	Healthy bool `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *HealthResponse) GetHealthy() bool

func (*HealthResponse) ProtoMessage()

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

func (x *HealthResponse) Reset()

func (x *HealthResponse) String() string

type HelloRequest ¶

type HelloRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *HelloRequest) GetName() string

func (*HelloRequest) ProtoMessage()

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

func (x *HelloRequest) Reset()

func (x *HelloRequest) String() string

type HelloResponse ¶

type HelloResponse struct {
	Reply string `protobuf:"bytes,1,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *HelloResponse) GetReply() string

func (*HelloResponse) ProtoMessage()

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

func (x *HelloResponse) Reset()

func (x *HelloResponse) String() string

type UnimplementedExampleKitServer ¶

type UnimplementedExampleKitServer struct {
}

UnimplementedExampleKitServer must be embedded to have forward compatible implementations.

type UnimplementedExampleServer ¶

type UnimplementedExampleServer struct {
}

UnimplementedExampleServer must be embedded to have forward compatible implementations.

func (UnimplementedExampleServer) Hello(Example_HelloServer) error

type UnimplementedV0KitServer ¶

type UnimplementedV0KitServer struct {
}

UnimplementedV0KitServer must be embedded to have forward compatible implementations.

func (UnimplementedV0KitServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)

type UnimplementedV0Server ¶

type UnimplementedV0Server struct {
}

UnimplementedV0Server must be embedded to have forward compatible implementations.

func (UnimplementedV0Server) Health(context.Context, *HealthRequest) (*HealthResponse, error)

type UnimplementedV1KitServer ¶

type UnimplementedV1KitServer struct {
}

UnimplementedV1KitServer must be embedded to have forward compatible implementations.

func (UnimplementedV1KitServer) GetDepartment(context.Context, *GetDepartmentRequest) (*GetDepartmentResponse, error)

type UnimplementedV1Server ¶

type UnimplementedV1Server struct {
}

UnimplementedV1Server must be embedded to have forward compatible implementations.

func (UnimplementedV1Server) GetDepartment(context.Context, *GetDepartmentRequest) (*GetDepartmentResponse, error)

type UnsafeExampleKitServer ¶

type UnsafeExampleKitServer interface {
	// contains filtered or unexported methods
}

UnsafeExampleKitServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExampleKitServer will result in compilation errors.

type UnsafeExampleServer ¶

type UnsafeExampleServer interface {
	// contains filtered or unexported methods
}

UnsafeExampleServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExampleServer will result in compilation errors.

type UnsafeV0KitServer ¶

type UnsafeV0KitServer interface {
	// contains filtered or unexported methods
}

UnsafeV0KitServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to V0KitServer will result in compilation errors.

type UnsafeV0Server ¶

type UnsafeV0Server interface {
	// contains filtered or unexported methods
}

UnsafeV0Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to V0Server will result in compilation errors.

type UnsafeV1KitServer ¶

type UnsafeV1KitServer interface {
	// contains filtered or unexported methods
}

UnsafeV1KitServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to V1KitServer will result in compilation errors.

type UnsafeV1Server ¶

type UnsafeV1Server interface {
	// contains filtered or unexported methods
}

UnsafeV1Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to V1Server will result in compilation errors.

type V0Client ¶

type V0Client interface {
	// 健康检查
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
}

V0Client is the client API for V0 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewV0Client(cc grpc.ClientConnInterface) V0Client

type V0KitClient ¶

type V0KitClient interface {
	// 健康检查
	Health(ctx context.Context, in *HealthRequest) (out *HealthResponse, err error)
}

V0KitClient is the go-kit client API for V0 service.

func NewV0KitClient(s V0KitEndpointSet) V0KitClient

type V0KitEndpointSet ¶

type V0KitEndpointSet struct {
	// 健康检查
	HealthEndpoint endpoint.Endpoint
}

V0KitEndpointSet is realize kit/endpoint.Endpoint

func NewV0KitEndpointSet(srv V0KitServer, mws ...endpoint.Middleware) V0KitEndpointSet

type V0KitGRPCHandlerSet ¶

type V0KitGRPCHandlerSet struct {
	HealthHandler *grpc.Server
}

V0KitGRPCHandlerSet is realize kit/transport/grpc.Server set.

func NewV0KitGRPCHandlerSet(
	set V0KitEndpointSet,
	transport V0KitGRPCTransport,
	opts ...grpc.ServerOption,
) V0KitGRPCHandlerSet

type V0KitGRPCTransport ¶

type V0KitGRPCTransport interface {
	DecodeHealthRequest(context.Context, interface{}) (interface{}, error)
	EncodeHealthResponse(context.Context, interface{}) (interface{}, error)
	EncodeHealthRequest(context.Context, interface{}) (interface{}, error)
	DecodeHealthResponse(context.Context, interface{}) (interface{}, error)
}

V0KitGRPCTransport defined from kit/transport/grpc.

type V0KitHTTPHandlerSet ¶

type V0KitHTTPHandlerSet struct {
	HealthHandler *http1.Server
}

V0KitHTTPHandlerSet is realize kit/transport/http.Server set.

func NewV0KitHTTPHandlerSet(
	set V0KitEndpointSet,
	transport V0KitHTTPTransport,
	opts ...http1.ServerOption,
) V0KitHTTPHandlerSet

type V0KitHTTPTransport ¶

type V0KitHTTPTransport interface {
	DecodeHealthRequest(context.Context, *http.Request) (interface{}, error)
	EncodeHealthResponse(context.Context, http.ResponseWriter, interface{}) error
	EncodeHealthRequest(context.Context, *http.Request, interface{}) error
	DecodeHealthResponse(context.Context, *http.Response) (interface{}, error)
}

V0KitHTTPTransport defined from kit/transport/http.

type V0KitServer ¶

type V0KitServer interface {
	// 健康检查
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// contains filtered or unexported methods
}

V0KitServer is the server API for V0 service. All implementations must embed UnimplementedV0KitServer for forward compatibility

type V0Server ¶

type V0Server interface {
	// 健康检查
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	// contains filtered or unexported methods
}

V0Server is the server API for V0 service. All implementations must embed UnimplementedV0Server for forward compatibility

type V1Client ¶

type V1Client interface {
	// 获取部门详情
	GetDepartment(ctx context.Context, in *GetDepartmentRequest, opts ...grpc.CallOption) (*GetDepartmentResponse, error)
}

V1Client is the client API for V1 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewV1Client(cc grpc.ClientConnInterface) V1Client

type V1KitClient ¶

type V1KitClient interface {
	// 获取部门详情
	GetDepartment(ctx context.Context, in *GetDepartmentRequest) (out *GetDepartmentResponse, err error)
}

V1KitClient is the go-kit client API for V1 service.

func NewV1KitClient(s V1KitEndpointSet) V1KitClient

type V1KitEndpointSet ¶

type V1KitEndpointSet struct {
	// 获取部门详情
	GetDepartmentEndpoint endpoint.Endpoint
}

V1KitEndpointSet is realize kit/endpoint.Endpoint

func NewV1KitEndpointSet(srv V1KitServer, mws ...endpoint.Middleware) V1KitEndpointSet

type V1KitGRPCHandlerSet ¶

type V1KitGRPCHandlerSet struct {
	GetDepartmentHandler *grpc.Server
}

V1KitGRPCHandlerSet is realize kit/transport/grpc.Server set.

func NewV1KitGRPCHandlerSet(
	set V1KitEndpointSet,
	transport V1KitGRPCTransport,
	opts ...grpc.ServerOption,
) V1KitGRPCHandlerSet

type V1KitGRPCTransport ¶

type V1KitGRPCTransport interface {
	DecodeGetDepartmentRequest(context.Context, interface{}) (interface{}, error)
	EncodeGetDepartmentResponse(context.Context, interface{}) (interface{}, error)
	EncodeGetDepartmentRequest(context.Context, interface{}) (interface{}, error)
	DecodeGetDepartmentResponse(context.Context, interface{}) (interface{}, error)
}

V1KitGRPCTransport defined from kit/transport/grpc.

type V1KitHTTPHandlerSet ¶

type V1KitHTTPHandlerSet struct {
	GetDepartmentHandler *http1.Server
}

V1KitHTTPHandlerSet is realize kit/transport/http.Server set.

func NewV1KitHTTPHandlerSet(
	set V1KitEndpointSet,
	transport V1KitHTTPTransport,
	opts ...http1.ServerOption,
) V1KitHTTPHandlerSet

type V1KitHTTPTransport ¶

type V1KitHTTPTransport interface {
	DecodeGetDepartmentRequest(context.Context, *http.Request) (interface{}, error)
	EncodeGetDepartmentResponse(context.Context, http.ResponseWriter, interface{}) error
	EncodeGetDepartmentRequest(context.Context, *http.Request, interface{}) error
	DecodeGetDepartmentResponse(context.Context, *http.Response) (interface{}, error)
}

V1KitHTTPTransport defined from kit/transport/http.

type V1KitServer ¶

type V1KitServer interface {
	// 获取部门详情
	GetDepartment(context.Context, *GetDepartmentRequest) (*GetDepartmentResponse, error)
	// contains filtered or unexported methods
}

V1KitServer is the server API for V1 service. All implementations must embed UnimplementedV1KitServer for forward compatibility

type V1Server ¶

type V1Server interface {
	// 获取部门详情
	GetDepartment(context.Context, *GetDepartmentRequest) (*GetDepartmentResponse, error)
	// contains filtered or unexported methods
}

V1Server is the server API for V1 service. All implementations must embed UnimplementedV1Server for forward compatibility