Documentation ¶ Index ¶ type Callback type Pub type PubSub type PublishOption type ReceiveOption type Sub Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Callback ¶ type Callback interface { // Finish finish the message Finish(ctx context.Context) error // Delay make the message visible again after interval Delay(ctx context.Context, duration time.Duration) error } type Pub ¶ type Pub interface { Publish(ctx context.Context, msg string, opt *PublishOption) error } type PubSub ¶ type PubSub interface { Pub Sub } type PublishOption ¶ type PublishOption struct { GroupID string TraceID string VisibleAt time.Time ExpiredAt time.Time } type ReceiveOption ¶ type ReceiveOption struct { VisibilityTimeout time.Duration } type Sub ¶ type Sub interface { Receive(ctx context.Context, opt *ReceiveOption) (string, Callback, error) } Source Files ¶ View all Source files pubsub.go Directories ¶ Show internal Expand all Path Synopsis sqs Click to show internal directories. Click to hide internal directories.