grpc

Documentation

Index

• type GRPCServerModule
  • func NewGRPCServerModule(name string, options *Options) *GRPCServerModule
  • func (p *GRPCServerModule) Cleanup(_ context.Context)
  • func (p *GRPCServerModule) Configure() error
  • func (p *GRPCServerModule) Init(ctx context.Context) error
  • func (p *GRPCServerModule) Main(_ context.Context) error
  • func (p *GRPCServerModule) PeriodicTasks() []*module.TaskConfig
• type Options
• type RegistryEntry

Types

type GRPCServerModule

type GRPCServerModule struct {
	module.Base

	Metrics *grpcprom.ServerMetrics
	// contains filtered or unexported fields
}

func NewGRPCServerModule

func NewGRPCServerModule(name string, options *Options) *GRPCServerModule

func (*GRPCServerModule) Cleanup

func (p *GRPCServerModule) Cleanup(_ context.Context)

func (*GRPCServerModule) Configure

func (p *GRPCServerModule) Configure() error

func (*GRPCServerModule) Init

func (p *GRPCServerModule) Init(ctx context.Context) error

func (*GRPCServerModule) Main

func (p *GRPCServerModule) Main(_ context.Context) error

func (*GRPCServerModule) PeriodicTasks

func (p *GRPCServerModule) PeriodicTasks() []*module.TaskConfig

type Options

type Options struct {
	ServiceRegistry []RegistryEntry
}

type RegistryEntry

type RegistryEntry struct {
	ServiceDesc grpc.ServiceDesc
	Service     interface{}
}