queue

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

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

type Consumer interface {
	ReceiveMessages(ctx context.Context, maxCount int) ([]Message, error)
	AckMessage(ctx context.Context, message Message) error
	Close() error
}

type Message interface {
	Body() string
}

type Producer interface {
	SendMessage(ctx context.Context, body string) error
	Close() error
}

type QueueService interface {
	CreateProducer() (Producer, error)
	CreateConsumer() (Consumer, error)
	Close() error
}

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

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

type TencentCloudQueueOption struct {
	Token string
	URL   string
}

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

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