grpc

Documentation

Index

• type GrpcHandler
  • func NewGrpcHandler(cfg GrpcSrvCfg) *GrpcHandler
  • func (s *GrpcHandler) ForceKill()
  • func (s *GrpcHandler) Serve(wg *sync.WaitGroup, stopch <-chan struct{}, errch chan<- error)
• type GrpcSrvCfg

Types

type GrpcHandler

type GrpcHandler struct {
	Srv *grpc.Server
	Cfg GrpcSrvCfg
}

[SrvHndlr] for gRPC services

func NewGrpcHandler

func NewGrpcHandler(cfg GrpcSrvCfg) *GrpcHandler

Create a new [GrpcHndlr]

func (*GrpcHandler) ForceKill

func (s *GrpcHandler) ForceKill()

func (*GrpcHandler) Serve

func (s *GrpcHandler) Serve(wg *sync.WaitGroup, stopch <-chan struct{}, errch chan<- error)

Implementation for the [SrvHdlr] interface

type GrpcSrvCfg

type GrpcSrvCfg struct {
	BindAddr string
	Port     uint16
}