requests

Documentation

Index

• Constants
• func GetBinding() amqp.Binding
• type RequestCallback
• type RequestManager
• type RequestManagerImpl
  • func New(broker amqp.MessageBroker) *RequestManagerImpl
  • func (manager *RequestManagerImpl) Listen()
  • func (manager *RequestManagerImpl) Request(s *discordgo.Session, i *discordgo.InteractionCreate, routingKey string, ...) error

Constants

const (
	AnswersExchange  = "amq.direct"
	AnswersQueueName = "answers"
)

Functions

func GetBinding

func GetBinding() amqp.Binding

Types

type RequestCallback

type RequestCallback func(ctx context.Context, s *discordgo.Session,
	i *discordgo.InteractionCreate, message *amqp.RabbitMQMessage, properties map[string]any)

type RequestManager

type RequestManager interface {
	Request(s *discordgo.Session, i *discordgo.InteractionCreate, routingKey string,
		message *amqp.RabbitMQMessage, callback RequestCallback, properties ...map[string]any) error
	Listen()
}

type RequestManagerImpl

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

func New

func New(broker amqp.MessageBroker) *RequestManagerImpl

func (*RequestManagerImpl) Listen

func (manager *RequestManagerImpl) Listen()

func (*RequestManagerImpl) Request

func (manager *RequestManagerImpl) Request(s *discordgo.Session, i *discordgo.InteractionCreate,
	routingKey string, message *amqp.RabbitMQMessage, callback RequestCallback,
	optionalProperties ...map[string]any) error