server

Documentation

Index

• Variables
• type GeneratorSvc
  • func NewGeneratorSvc(sl core.StatusLoader, cl core.ConfigLoader) *GeneratorSvc
  • func (gsvc *GeneratorSvc) Moudles(ctx context.Context, req *v1.MoudlesReq) (*v1.MoudlesReply, error)
  • func (gsvc *GeneratorSvc) NextID(ctx context.Context, req *v1.NextIDReq) (*v1.NextIDReply, error)
  • func (gsvc *GeneratorSvc) RegisterModules(ctx context.Context, req *v1.RegisterModulesReq) (*v1.RegisterModulesReply, error)
• type GrpcServer
  • func NewGrpcServer(gs *GeneratorSvc, c *conf.Server) *GrpcServer
  • func (s *GrpcServer) Start() error
  • func (s *GrpcServer) Stop()

Variables

var ProviderSet = wire.NewSet(NewGeneratorSvc, NewGrpcServer)

Types

type GeneratorSvc

type GeneratorSvc struct {
	v1.UnimplementedGeneratorServer
	v1.UnimplementedMannagerServer
	// contains filtered or unexported fields
}

func NewGeneratorSvc

func NewGeneratorSvc(sl core.StatusLoader, cl core.ConfigLoader) *GeneratorSvc

func (*GeneratorSvc) Moudles

func (gsvc *GeneratorSvc) Moudles(ctx context.Context, req *v1.MoudlesReq) (*v1.MoudlesReply, error)

func (*GeneratorSvc) NextID

func (gsvc *GeneratorSvc) NextID(ctx context.Context, req *v1.NextIDReq) (*v1.NextIDReply, error)

func (*GeneratorSvc) RegisterModules

func (gsvc *GeneratorSvc) RegisterModules(ctx context.Context, req *v1.RegisterModulesReq) (*v1.RegisterModulesReply, error)

type GrpcServer

type GrpcServer struct {
	Addr string
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer(gs *GeneratorSvc, c *conf.Server) *GrpcServer

NewServer new gRPC server instance

func (*GrpcServer) Start

func (s *GrpcServer) Start() error

Start start gRPC server

func (*GrpcServer) Stop

func (s *GrpcServer) Stop()

Stop stop gRPC server