Documentation
¶
Index ¶
- Constants
- type Sqs
- func (this *Sqs) Disconnect() error
- func (this Sqs) Healthy(ctx context.Context) error
- func (this *Sqs) Init(queues []string) (err error)
- func (this Sqs) MaxConcurrentDrainWorkers() int
- func (this Sqs) Pop(ctx context.Context, queueName string, handler types.Handler) error
- func (this Sqs) Publish(ctx context.Context, queueName string, payload *types.Task) error
- func (this Sqs) Purge(ctx context.Context, queueName string) error
- func (this Sqs) PurgeMatching(ctx context.Context, queueName, substr string) error
- func (this Sqs) Subscribe(ctx context.Context, queueName string, handler types.Handler) (err error)
- func (this Sqs) Suck(ctx context.Context, queueName string, handler types.Handler) (err error)
Constants ¶
View Source
const FIFTEEN_MINUTES = (15 * time.Minute)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sqs ¶
type Sqs struct {
// contains filtered or unexported fields
}
func (*Sqs) Disconnect ¶
func (Sqs) MaxConcurrentDrainWorkers ¶ added in v3.0.9
func (Sqs) PurgeMatching ¶
Source Files
Click to show internal directories.
Click to hide internal directories.