hservice

Documentation

Index

• type Executor
• type GrpcClientCreator
  • func NewGrpcClientCreator() *GrpcClientCreator
  • func (r *GrpcClientCreator) HelloServiceClient(connection *grpc.ClientConn) proto.HelloServiceClient
  • func (r *GrpcClientCreator) QueryDataServiceClient(connection *grpc.ClientConn) proto.QueryDataServiceClient
• type HelloService
  • func NewHelloService(console *zap.Logger, grpcConnection *grpc.ClientConn, ...) HelloService
  • func (a *HelloService) HelloService(context context.Context, req *proto.HelloRequest) (*proto.HelloResponse, error)
  • func (a *HelloService) QueryDataService(context context.Context, req *proto.TransactionQueryRequest) (grpc.ServerStreamingClient[proto.TransactionQueryResponse], error)
• type HelloServiceCreator

Types

type Executor

type Executor interface {
	HelloService(context context.Context, req *proto.HelloRequest) (*proto.HelloResponse, error)
	QueryDataService(context context.Context, req *proto.TransactionQueryRequest) (grpc.ServerStreamingClient[proto.TransactionQueryResponse], error)
}

type GrpcClientCreator

type GrpcClientCreator struct {
}

func NewGrpcClientCreator

func NewGrpcClientCreator() *GrpcClientCreator

func (*GrpcClientCreator) HelloServiceClient

func (r *GrpcClientCreator) HelloServiceClient(connection *grpc.ClientConn) proto.HelloServiceClient

func (*GrpcClientCreator) QueryDataServiceClient

func (r *GrpcClientCreator) QueryDataServiceClient(connection *grpc.ClientConn) proto.QueryDataServiceClient

type HelloService

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

func NewHelloService

func NewHelloService(
	console *zap.Logger,
	grpcConnection *grpc.ClientConn,
	helloServiceCreator HelloServiceCreator,
) HelloService

func (*HelloService) HelloService

func (a *HelloService) HelloService(context context.Context, req *proto.HelloRequest) (*proto.HelloResponse, error)

func (*HelloService) QueryDataService

func (a *HelloService) QueryDataService(context context.Context, req *proto.TransactionQueryRequest) (grpc.ServerStreamingClient[proto.TransactionQueryResponse], error)

type HelloServiceCreator

type HelloServiceCreator interface {
	HelloServiceClient(connection *grpc.ClientConn) proto.HelloServiceClient
	QueryDataServiceClient(connection *grpc.ClientConn) proto.QueryDataServiceClient
}