queues

Documentation

Index

• Constants
• func New(id string, logger *zap.Logger) *server
• type SessionStore

Constants

const (
	QueueCreated            string = "queue_created"
	QueueDeleted            string = "queue_delete"
	QueueMessagePut         string = "queue_message_put"
	QueueMessagePutBatch    string = "queue_message_put_batch"
	QueueMessageDeleted     string = "queue_message_deleted"
	QueueMessageSetInflight string = "queue_message_set_inflight"
	MessageInflightExpired  string = "queue_message_inflight_expired"
	QueueMessageAcked       string = "queue_message_acked"
)

Functions

func New

func New(id string, logger *zap.Logger) *server

Types

type SessionStore

type SessionStore interface {
	ByID(ctx context.Context, id string) (*sessions.Session, error)
	All(ctx context.Context, filters ...sessions.SessionFilter) ([]*sessions.Session, error)
}