service

Documentation

Index

• type Commander
  • func NewCommander(db *sqlx.DB, rc *redis.Client, sess *discordgo.Session, ...) (*Commander, error)
  • func (c *Commander) Run() error
• type RegistrarHandler
• type RegistrarWorker
  • func NewRegistrarWorker(registrar *discovery.ConsulDiscovery) *RegistrarWorker
  • func (r *RegistrarWorker) AddRegistrarHandler(handler discovery.HandlerFunc)
  • func (r *RegistrarWorker) Run(name string)

Types

type Commander

type Commander struct {
	Users     *users.Service
	Discord   *worker.DiscordWorker
	Registrar *RegistrarWorker
	// contains filtered or unexported fields
}

func NewCommander

func NewCommander(db *sqlx.DB, rc *redis.Client, sess *discordgo.Session, cd *consul.ConsulDiscovery, rabbit *amqp.Connection, logger *zap.Logger) (*Commander, error)

func (*Commander) Run

func (c *Commander) Run() error

type RegistrarHandler

type RegistrarHandler func(id uuid.UUID, command string)

type RegistrarWorker

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

func NewRegistrarWorker

func NewRegistrarWorker(registrar *discovery.ConsulDiscovery) *RegistrarWorker

func (*RegistrarWorker) AddRegistrarHandler

func (r *RegistrarWorker) AddRegistrarHandler(handler discovery.HandlerFunc)

func (*RegistrarWorker) Run

func (r *RegistrarWorker) Run(name string)