grpc

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 28, 2022 License: LGPL-2.1 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ErrorHandlerGrpc added in v0.2.2

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

Types

type GrpcConfig added in v0.2.2

type GrpcConfig struct {
	Listen string `json:"Listen,omitempty" config:"Listen,required"`
	Port   int16  `json:"Port,omitempty" config:"Port,required"`
}

type GrpcServiceWorker added in v0.2.2

type GrpcServiceWorker struct {
	*worker.BaseWorker
	// contains filtered or unexported fields
}

func NewGrpcServiceWorker added in v0.2.2

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

func (*GrpcServiceWorker) AddRegFunc added in v0.2.2

func (*GrpcServiceWorker) Run added in v0.2.2

func (w *GrpcServiceWorker) Run()

func (*GrpcServiceWorker) SetErrorHandler added in v0.2.2

func (*GrpcServiceWorker) Setup added in v0.2.2

func (w *GrpcServiceWorker) Setup()

func (*GrpcServiceWorker) Stop added in v0.2.2

func (w *GrpcServiceWorker) Stop()

type RegFuncGrpcServiceWorker added in v0.2.2

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL