diff --git a/internal/proxy/director/layer/queue/adapter.go b/internal/proxy/director/layer/queue/adapter.go index 748694e..d8f215e 100644 --- a/internal/proxy/director/layer/queue/adapter.go +++ b/internal/proxy/director/layer/queue/adapter.go @@ -10,7 +10,10 @@ type Status struct { } type Adapter interface { + // Touch updates the session TTL and returns its current rank Touch(ctx context.Context, queueName string, sessionId string) (int64, error) + // Status returns the queue current status Status(ctx context.Context, queueName string) (*Status, error) + // Refresh forces a refresh of the queue, taking into account the given TTL for sessions Refresh(ctx context.Context, queueName string, keepAlive time.Duration) error }