orchestrator

Documentation

Index

• func NewLockHandler(rdb *redis.Client) *lockHandler
• type Config
  • func NewConfigFromEnv() Config
• type LockHandler
• type QueueHandler
• type TaskOrchestrationServer
  • func NewTaskOrchestratorServer(cfg Config) *TaskOrchestrationServer
  • func (s *TaskOrchestrationServer) StartServer(ctx context.Context)

Functions

func NewLockHandler

func NewLockHandler(rdb *redis.Client) *lockHandler

Types

type Config

type Config struct {
	RedisIP       string
	RedisPort     int
	RedisPassword string
	RedisDB       int
}

func NewConfigFromEnv

func NewConfigFromEnv() Config

type LockHandler

type LockHandler interface {
	AcquireLock(ctx context.Context, key string, acquisitionTimeout time.Duration, lockTimeout time.Duration) (lockID string, err error)
	ReleaseLock(ctx context.Context, key string, lockID string) error
}

type QueueHandler

type QueueHandler interface {
	ExecuteTopTask(ctx context.Context) error
	MoveDueDelayedTasks(ctx context.Context, dueBefore time.Time) error
}

type TaskOrchestrationServer

type TaskOrchestrationServer struct {
	// contains filtered or unexported fields
}

func NewTaskOrchestratorServer

func NewTaskOrchestratorServer(cfg Config) *TaskOrchestrationServer

func (*TaskOrchestrationServer) StartServer

func (s *TaskOrchestrationServer) StartServer(ctx context.Context)