service

package

v0.0.0-...-c30b888 Latest Latest Go to latest Published: Jan 14, 2024 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(NewLsmdbService, NewEtcdService)

ProviderSet is service providers.

This section is empty.

type EtcdService struct {
	pb.UnimplementedEtcdServer
	// contains filtered or unexported fields
}

func NewEtcdService(etcd *biz.EtcdUsecase) *EtcdService

func (s *EtcdService) Get(ctx context.Context, req *pb.EtcdGetRequest) (*pb.EtcdGetReply, error)

func (s *EtcdService) Put(ctx context.Context, req *pb.EtcdPutRequest) (*pb.EtcdPutReply, error)

type JavaDemoServiceService struct {
	pb.UnimplementedJavaDemoServiceServer
}

func NewJavaDemoServiceService() *JavaDemoServiceService

func (s *JavaDemoServiceService) HelloWorld(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error)

func (s *JavaDemoServiceService) HelloWorldClientAndServerStream(conn pb.JavaDemoService_HelloWorldClientAndServerStreamServer) error

func (s *JavaDemoServiceService) HelloWorldClientStream(conn pb.JavaDemoService_HelloWorldClientStreamServer) error

type LsmdbService struct {
	pb.UnimplementedLsmdbServer
	// contains filtered or unexported fields
}

func NewLsmdbService(uc *biz.LevelDBUsecase, logger log.Logger, etcd *biz.EtcdUsecase, oss *biz.OssUsecase) *LsmdbService

func (s *LsmdbService) Get(ctx context.Context, req *pb.GetRequest) (*pb.GetReply, error)

func (s *LsmdbService) OpenDB(ctx context.Context, req *pb.OpenDBRequest) (*pb.OpenDBReply, error)

func (s *LsmdbService) Put(ctx context.Context, req *pb.PutRequest) (*pb.PutReply, error)

func (s *LsmdbService) PutStr(ctx context.Context, req *pb.PutStrRequest) (*pb.PutStrReply, error)

type RegisterService struct {
	pb.UnimplementedRegisterServer
}

func NewRegisterService() *RegisterService

func (s *RegisterService) Register(ctx context.Context, req *pb.RegisterRequest) (*pb.RegisterReply, error)