registrart

Documentation

Index

• type RabbitRegistrarTransport
  • func NewRabbitRegistrarTransport(conn *amqp.Connection, logger *zap.Logger) (*RabbitRegistrarTransport, error)
  • func (t *RabbitRegistrarTransport) AddHandler(handler RegistrarHandler)
  • func (t *RabbitRegistrarTransport) Close()
  • func (t *RabbitRegistrarTransport) RegisterCommand(id uuid.UUID, command string) error
  • func (t *RabbitRegistrarTransport) Start() error
• type RegistrarHandler
• type RegistrarMessage
• type RegistrarReceiver
• type RegistrarSender

Types

type RabbitRegistrarTransport

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

func NewRabbitRegistrarTransport

func NewRabbitRegistrarTransport(conn *amqp.Connection, logger *zap.Logger) (*RabbitRegistrarTransport, error)

func (*RabbitRegistrarTransport) AddHandler

func (t *RabbitRegistrarTransport) AddHandler(handler RegistrarHandler)

AddHandler adds a handler to the worker

func (*RabbitRegistrarTransport) Close

func (t *RabbitRegistrarTransport) Close()

func (*RabbitRegistrarTransport) RegisterCommand

func (t *RabbitRegistrarTransport) RegisterCommand(id uuid.UUID, command string) error

func (*RabbitRegistrarTransport) Start

func (t *RabbitRegistrarTransport) Start() error

type RegistrarHandler

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

type RegistrarMessage

type RegistrarMessage struct {
	ID      uuid.UUID `json:"guild_id"`
	Command string    `json:"user_id"`
}

type RegistrarReceiver

type RegistrarReceiver interface {
	AddHandler(handler RegistrarHandler)
	Start() error
	Close()
}

type RegistrarSender

type RegistrarSender interface {
	RegisterCommand(id uuid.UUID, command string) error
}