Documentation ¶
Overview ¶
delayd2 is an available setTimeout() service for scheduling message sends
Index ¶
- Variables
- func BuildBatchMap(messages []*QueueMessage) map[string][][]releaseMessage
- func BuildPlaceHolders(n int) string
- func SendMessageBatch(s *sqs.SQS, req *sqs.SendMessageBatchInput, id2index map[string]int) error
- type Consumer
- type Driver
- type QueueMessage
- type Relay
- type Sender
- type Worker
- type WorkerConfig
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrMessageDuplicated = errors.New("driver: message is duplicated") ErrSessionRegistered = errors.New("driver: session is already registered") )
View Source
var ErrInvalidAttributes = errors.New("delayd2: invalid attributes")
View Source
var ErrTooManyPayloads = errors.New("relay: too many payloads. Up to 10 payloads can be sent at once")
Functions ¶
func BuildBatchMap ¶
func BuildBatchMap(messages []*QueueMessage) map[string][][]releaseMessage
func BuildPlaceHolders ¶
func SendMessageBatch ¶
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer represents a SQS message consumer.
func (*Consumer) ConsumeMessages ¶
ConsumeMessages consumes messages in SQS queue. It returns the number of consumed message in success.
type Driver ¶
type Driver interface { RegisterSession() error DeregisterSession() error KeepAliveSession() error Enqueue(string, int64, string, string) error ResetActive() (int64, error) MarkActive(time.Time) (int64, error) MarkOrphaned() error AdoptOrphans() (int64, error) RemoveMessages([]string) error GetActiveMessages() ([]*QueueMessage, error) }
type QueueMessage ¶
type QueueMessage struct { QueueID string WorkerID string ReleaseAt time.Time RelayTo string Payload string }
QueueMessage is a message queued in the database.
type Sender ¶
type Sender struct {
// contains filtered or unexported fields
}
func (*Sender) SendMessage ¶
Click to show internal directories.
Click to hide internal directories.