signal

Documentation

Index

• type AuthConfig
  • func (a AuthConfig) KeyFunc(t *jwt.Token) (interface{}, error)
• type Config
• type Signal
  • func NewSignal(conf Config) (*Signal, error)
  • func (s *Signal) Close()
  • func (s *Signal) Director(ctx context.Context, fullMethodName string) (context.Context, grpc.ClientConnInterface, error)
  • func (s *Signal) Start() error

Types

type AuthConfig

type AuthConfig struct {
	Enabled bool   `mapstructure:"enabled"`
	Key     string `mapstructure:"key"`
	KeyType string `mapstructure:"key_type"`
}

AuthConfig auth config

func (AuthConfig) KeyFunc

func (a AuthConfig) KeyFunc(t *jwt.Token) (interface{}, error)

KeyFunc auth key types

type Config

type Config struct {
	Global global     `mapstructure:"global"`
	Log    logConf    `mapstructure:"log"`
	Nats   natsConf   `mapstructure:"nats"`
	Node   nodeConf   `mapstructure:"node"`
	Avp    avpConf    `mapstructure:"avp"`
	Signal signalConf `mapstructure:"signal"`
}

Config for biz node

type Signal

type Signal struct {
	ion.Node
	// contains filtered or unexported fields
}

func NewSignal

func NewSignal(conf Config) (*Signal, error)

func (*Signal) Close

func (s *Signal) Close()

func (*Signal) Director

func (s *Signal) Director(ctx context.Context, fullMethodName string) (context.Context, grpc.ClientConnInterface, error)

func (*Signal) Start

func (s *Signal) Start() error