gate

Documentation

Index

• Variables
• type Gate
  • func NewGate(opts ...Option) *Gate
  • func (g *Gate) Destroy()
  • func (g *Gate) Init()
  • func (g *Gate) Name() string
  • func (g *Gate) Start()
• type Option
  • func WithContext(ctx context.Context) Option
  • func WithGRPCServer(grpc *grpc.Server) Option
  • func WithID(id string) Option
  • func WithName(name string) Option
  • func WithRedis(redis redis.Client) Option
  • func WithRegistry(r registry.Registry) Option
  • func WithServer(s network.Server) Option
  • func WithTimeout(timeout time.Duration) Option

Variables

var (
	ErrNotFoundUserSource = errors.New("not found user source")
)

Types

type Gate

type Gate struct {
	component.Base
	// contains filtered or unexported fields
}

func NewGate

func NewGate(opts ...Option) *Gate

func (*Gate) Destroy

func (g *Gate) Destroy()

Destroy 销毁组件

func (*Gate) Init

func (g *Gate) Init()

Init 初始化

func (*Gate) Name

func (g *Gate) Name() string

Name 组件名称

func (*Gate) Start

func (g *Gate) Start()

Start 启动组件

type Option

type Option func(o *options)

func WithContext

func WithContext(ctx context.Context) Option

WithContext 设置上下文

func WithGRPCServer

func WithGRPCServer(grpc *grpc.Server) Option

WithGRPCServer 设置GRPC服务器

func WithID

func WithID(id string) Option

WithID 设置实例ID

func WithName

func WithName(name string) Option

WithName 设置实例名称

func WithRedis

func WithRedis(redis redis.Client) Option

WithRedis 设置redis客户端

func WithRegistry

func WithRegistry(r registry.Registry) Option

WithRegistry 设置服务注册

func WithServer

func WithServer(s network.Server) Option

WithServer 设置服务器

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout 设置RPC调用超时时间