grpc

type Application ¶

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

func NewApplication(config config.Config) *Application

func (app *Application) Client(ctx context.Context, name string) (*grpc.ClientConn, error)

func (app *Application) Listen(l net.Listener) error

func (app *Application) Run(host ...string) error

func (app *Application) Server() *grpc.Server

func (app *Application) Shutdown(force ...bool) error

func (app *Application) UnaryClientInterceptorGroups(unaryClientInterceptorGroups map[string][]grpc.UnaryClientInterceptor)

func (app *Application) UnaryServerInterceptors(unaryServerInterceptors []grpc.UnaryServerInterceptor)

type ServiceProvider ¶

type ServiceProvider struct {
}

func (r *ServiceProvider) Boot(app foundation.Application)

func (r *ServiceProvider) Register(app foundation.Application)

func (r *ServiceProvider) Relationship() binding.Relationship

type TestRequest ¶ added in v1.8.0

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

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

func (x *TestRequest) GetName() string

func (*TestRequest) ProtoMessage()

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

func (x *TestRequest) Reset()

func (x *TestRequest) String() string

type TestResponse ¶ added in v1.8.0

type TestResponse struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *TestResponse) GetCode() int32

func (x *TestResponse) GetMessage() string

func (*TestResponse) ProtoMessage()

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

func (x *TestResponse) Reset()

func (x *TestResponse) String() string

type TestServiceClient ¶ added in v1.8.0

type TestServiceClient interface {
	Get(ctx context.Context, in *TestRequest, opts ...grpc.CallOption) (*TestResponse, error)
}

TestServiceClient is the client API for TestService 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 NewTestServiceClient(cc grpc.ClientConnInterface) TestServiceClient

type TestServiceServer ¶ added in v1.8.0

type TestServiceServer interface {
	Get(context.Context, *TestRequest) (*TestResponse, error)
	// contains filtered or unexported methods
}

TestServiceServer is the server API for TestService service. All implementations must embed UnimplementedTestServiceServer for forward compatibility

type UnimplementedTestServiceServer ¶ added in v1.8.0

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) Get(context.Context, *TestRequest) (*TestResponse, error)

type UnsafeTestServiceServer ¶ added in v1.15.12

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

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