grpc

Documentation

Index

• Constants
• type Grpc
  • func Get() *Grpc
  • func (g *Grpc) AddInterceptors(interceptors ...grpc.UnaryServerInterceptor)
  • func (g *Grpc) Addr() string
  • func (g *Grpc) Init() error
  • func (g *Grpc) Interceptors() (interceptors []grpc.UnaryServerInterceptor)
  • func (g *Grpc) IsEnable() bool
  • func (g *Grpc) Name() string
  • func (i *Grpc) Priority() int
  • func (g *Grpc) Server() *grpc.Server
  • func (g *Grpc) ServerOpts() []grpc.ServerOption
  • func (g *Grpc) Start(ctx context.Context)
  • func (g *Grpc) Stop(ctx context.Context) error
• type ServiceInfoCtxKey

Constants

const (
	AppName = "grpc"
)

Types

type Grpc

type Grpc struct {
	ioc.ObjectImpl

	// 开启GRPC服务
	Enable *bool  `json:"enable" yaml:"enable" toml:"enable" env:"ENABLE"`
	Host   string `json:"host" yaml:"host" toml:"host" env:"HOST"`
	Port   int    `json:"port" yaml:"port" toml:"port" env:"PORT"`

	EnableSSL bool   `json:"enable_ssl" yaml:"enable_ssl" toml:"enable_ssl" env:"ENABLE_SSL"`
	CertFile  string `json:"cert_file" yaml:"cert_file" toml:"cert_file" env:"CERT_FILE"`
	KeyFile   string `json:"key_file" yaml:"key_file" toml:"key_file" env:"KEY_FILE"`

	// 开启recovery恢复
	Recovery bool `json:"recovery" yaml:"recovery" toml:"recovery" env:"RECOVERY"`
	// 开启Trace
	Trace bool `json:"trace" yaml:"trace" toml:"trace" env:"TRACE"`

	// 启动后执行
	PostStart func(context.Context) error `json:"-" yaml:"-" toml:"-" env:"-"`
	// 关闭前执行
	PreStop func(context.Context) error `json:"-" yaml:"-" toml:"-" env:"-"`
	// contains filtered or unexported fields
}

func Get

func Get() *Grpc

func (*Grpc) AddInterceptors

func (g *Grpc) AddInterceptors(interceptors ...grpc.UnaryServerInterceptor)

func (*Grpc) Addr

func (g *Grpc) Addr() string

func (*Grpc) Init

func (g *Grpc) Init() error

func (*Grpc) Interceptors

func (g *Grpc) Interceptors() (interceptors []grpc.UnaryServerInterceptor)

func (*Grpc) IsEnable

func (g *Grpc) IsEnable() bool

func (*Grpc) Name

func (g *Grpc) Name() string

func (*Grpc) Priority

func (i *Grpc) Priority() int

func (*Grpc) Server

func (g *Grpc) Server() *grpc.Server

func (*Grpc) ServerOpts

func (g *Grpc) ServerOpts() []grpc.ServerOption

func (*Grpc) Start

func (g *Grpc) Start(ctx context.Context)

func (*Grpc) Stop

func (g *Grpc) Stop(ctx context.Context) error

type ServiceInfoCtxKey

type ServiceInfoCtxKey struct{}