package queue import ( "context" "time" ) type Status struct { Sessions int64 } type Adapter interface { Touch(ctx context.Context, queueName string, sessionId string) (int64, error) Status(ctx context.Context, queueName string) (*Status, error) Refresh(ctx context.Context, queueName string, keepAlive time.Duration) error }