server

Documentation

Index

• Variables
• func UnaryClient(interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption
• func UnaryServer(interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption
• type GrpcServer
  • func NewGrpcServer(options ...Option) *GrpcServer
  • func (g *GrpcServer) Registry(reg registry.Registry, serOpts ...registry.ServerOpt) error
  • func (g *GrpcServer) RegistryStopFunc(f func())
  • func (g *GrpcServer) Run() error
  • func (g *GrpcServer) Server() grpc.ServiceRegistrar
  • func (g *GrpcServer) WatchSignal()
• type Option
  • func WithCtx(ctx context.Context) Option
  • func WithGrpcOpts(option ...grpc.ServerOption) Option
  • func WithHdlrWrappers(wrapper ...grpc.UnaryServerInterceptor) Option
  • func WithListenAddr(addr string) Option
  • func WithMode(mode string) Option
  • func WithName(name string) Option
  • func WithNamespace(namespace string) Option
• type Options

Variables

var (
	// DefaultMaxMsgSize define maximum message size that server can send
	// or receive.  Default value is 4MB.
	DefaultMaxMsgSize = 1024 * 1024 * 4
)

Functions

func UnaryClient

func UnaryClient(interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption

func UnaryServer

func UnaryServer(interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption

Types

type GrpcServer

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

func NewGrpcServer

func NewGrpcServer(options ...Option) *GrpcServer

func (*GrpcServer) Registry

func (g *GrpcServer) Registry(reg registry.Registry, serOpts ...registry.ServerOpt) error

func (*GrpcServer) RegistryStopFunc

func (g *GrpcServer) RegistryStopFunc(f func())

func (*GrpcServer) Run

func (g *GrpcServer) Run() error

func (*GrpcServer) Server

func (g *GrpcServer) Server() grpc.ServiceRegistrar

func (*GrpcServer) WatchSignal

func (g *GrpcServer) WatchSignal()

type Option

type Option func(*Options)

func WithCtx

func WithCtx(ctx context.Context) Option

func WithGrpcOpts

func WithGrpcOpts(option ...grpc.ServerOption) Option

func WithHdlrWrappers

func WithHdlrWrappers(wrapper ...grpc.UnaryServerInterceptor) Option

func WithListenAddr

func WithListenAddr(addr string) Option

func WithMode

func WithMode(mode string) Option

mode release,debug

func WithName

func WithName(name string) Option

func WithNamespace

func WithNamespace(namespace string) Option

type Options

type Options struct {
	Name           string
	ListenAddr     string
	Namespace      string
	Version        string
	Mode           string //debubg product
	Ctx            context.Context
	GrpcOpts       []grpc.ServerOption
	HandleWrappers []grpc.UnaryServerInterceptor
}