grpc

Aug 7, 2022

Changes in this version

+ func ErrorHandlerGrpc(ctx context.Context, p interface{}) (err error)

+ type GrpcConfig struct

+ Listen string

+ Port int16

+ type GrpcServiceWorker struct

+ func NewGrpcServiceWorker(name string, config *GrpcConfig) *GrpcServiceWorker

+ func (w *GrpcServiceWorker) AddRegFunc(f RegFuncGrpcServiceWorker)

+ func (w *GrpcServiceWorker) Run()

+ func (w *GrpcServiceWorker) SetErrorHandler(f grpc_recovery.RecoveryHandlerFuncContext)

+ func (w *GrpcServiceWorker) Setup()

+ func (w *GrpcServiceWorker) Stop()

+ type RegFuncGrpcServiceWorker func(s *grpc.Server, wc *worker.WorkerAdapters)

Feb 13, 2022

Changes in this version

+ type ServiceGrpc struct

+ func NewServiceGrpc(config *worker.WorkerConfig) *ServiceGrpc

+ func (w *ServiceGrpc) AddService(f func(s *grpc.Server, wc *worker.WorkerContexts))

+ func (w *ServiceGrpc) Run()

+ func (w *ServiceGrpc) Setup()

+ func (w *ServiceGrpc) Stop()