taskqueue

Documentation

Index

• Constants
• Variables
• type RedisTaskQueue
  • func (tq *RedisTaskQueue) InstanceFactory(ctx context.Context, stubId string, ...) (abstractions.IAutoscaledInstance, error)
  • func (tq *RedisTaskQueue) StartTaskQueueServe(ctx context.Context, req *pb.StartTaskQueueServeRequest) (*pb.StartTaskQueueServeResponse, error)
  • func (tq *RedisTaskQueue) TaskQueueComplete(ctx context.Context, in *pb.TaskQueueCompleteRequest) (*pb.TaskQueueCompleteResponse, error)
  • func (tq *RedisTaskQueue) TaskQueueLength(ctx context.Context, in *pb.TaskQueueLengthRequest) (*pb.TaskQueueLengthResponse, error)
  • func (tq *RedisTaskQueue) TaskQueueMonitor(req *pb.TaskQueueMonitorRequest, ...) error
  • func (tq *RedisTaskQueue) TaskQueuePop(ctx context.Context, in *pb.TaskQueuePopRequest) (*pb.TaskQueuePopResponse, error)
  • func (tq *RedisTaskQueue) TaskQueuePut(ctx context.Context, in *pb.TaskQueuePutRequest) (*pb.TaskQueuePutResponse, error)
• type TaskQueueService
  • func NewRedisTaskQueueService(ctx context.Context, opts TaskQueueServiceOpts) (TaskQueueService, error)
• type TaskQueueServiceOpts
• type TaskQueueTask
  • func (t *TaskQueueTask) Cancel(ctx context.Context, reason types.TaskCancellationReason) error
  • func (t *TaskQueueTask) Execute(ctx context.Context, options ...interface{}) error
  • func (t *TaskQueueTask) HeartBeat(ctx context.Context) (bool, error)
  • func (t *TaskQueueTask) Message() *types.TaskMessage
  • func (t *TaskQueueTask) Metadata() types.TaskMetadata
  • func (t *TaskQueueTask) Retry(ctx context.Context) error

Constants

const (
	DefaultTaskQueueTaskTTL uint32 = 3600 * 2 // 2 hours

)

Variables

var Keys = &keys{}

Types

type RedisTaskQueue

type RedisTaskQueue struct {
	pb.UnimplementedTaskQueueServiceServer
	// contains filtered or unexported fields
}

func (*RedisTaskQueue) InstanceFactory

func (tq *RedisTaskQueue) InstanceFactory(ctx context.Context, stubId string, options ...func(abstractions.IAutoscaledInstance)) (abstractions.IAutoscaledInstance, error)

func (*RedisTaskQueue) StartTaskQueueServe

func (tq *RedisTaskQueue) StartTaskQueueServe(ctx context.Context, req *pb.StartTaskQueueServeRequest) (*pb.StartTaskQueueServeResponse, error)

func (*RedisTaskQueue) TaskQueueComplete

func (tq *RedisTaskQueue) TaskQueueComplete(ctx context.Context, in *pb.TaskQueueCompleteRequest) (*pb.TaskQueueCompleteResponse, error)

func (*RedisTaskQueue) TaskQueueLength

func (tq *RedisTaskQueue) TaskQueueLength(ctx context.Context, in *pb.TaskQueueLengthRequest) (*pb.TaskQueueLengthResponse, error)

func (*RedisTaskQueue) TaskQueueMonitor

func (tq *RedisTaskQueue) TaskQueueMonitor(req *pb.TaskQueueMonitorRequest, stream pb.TaskQueueService_TaskQueueMonitorServer) error

func (*RedisTaskQueue) TaskQueuePop

func (tq *RedisTaskQueue) TaskQueuePop(ctx context.Context, in *pb.TaskQueuePopRequest) (*pb.TaskQueuePopResponse, error)

func (*RedisTaskQueue) TaskQueuePut

func (tq *RedisTaskQueue) TaskQueuePut(ctx context.Context, in *pb.TaskQueuePutRequest) (*pb.TaskQueuePutResponse, error)

type TaskQueueService

type TaskQueueService interface {
	pb.TaskQueueServiceServer
	TaskQueuePut(ctx context.Context, req *pb.TaskQueuePutRequest) (*pb.TaskQueuePutResponse, error)
	TaskQueuePop(ctx context.Context, req *pb.TaskQueuePopRequest) (*pb.TaskQueuePopResponse, error)
	TaskQueueLength(ctx context.Context, req *pb.TaskQueueLengthRequest) (*pb.TaskQueueLengthResponse, error)
	TaskQueueComplete(ctx context.Context, req *pb.TaskQueueCompleteRequest) (*pb.TaskQueueCompleteResponse, error)
	TaskQueueMonitor(req *pb.TaskQueueMonitorRequest, stream pb.TaskQueueService_TaskQueueMonitorServer) error
	StartTaskQueueServe(ctx context.Context, req *pb.StartTaskQueueServeRequest) (*pb.StartTaskQueueServeResponse, error)
}

func NewRedisTaskQueueService

func NewRedisTaskQueueService(
	ctx context.Context,
	opts TaskQueueServiceOpts,
) (TaskQueueService, error)

type TaskQueueServiceOpts

type TaskQueueServiceOpts struct {
	Config           types.AppConfig
	RedisClient      *common.RedisClient
	BackendRepo      repository.BackendRepository
	WorkspaceRepo    repository.WorkspaceRepository
	TaskRepo         repository.TaskRepository
	ContainerRepo    repository.ContainerRepository
	Scheduler        *scheduler.Scheduler
	Tailscale        *network.Tailscale
	RouteGroup       *echo.Group
	TaskDispatcher   *task.Dispatcher
	EventRepo        repository.EventRepository
	UsageMetricsRepo repository.UsageMetricsRepository
}

type TaskQueueTask

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

func (*TaskQueueTask) Cancel

func (t *TaskQueueTask) Cancel(ctx context.Context, reason types.TaskCancellationReason) error

func (*TaskQueueTask) Execute

func (t *TaskQueueTask) Execute(ctx context.Context, options ...interface{}) error

func (*TaskQueueTask) HeartBeat

func (t *TaskQueueTask) HeartBeat(ctx context.Context) (bool, error)

func (*TaskQueueTask) Message

func (t *TaskQueueTask) Message() *types.TaskMessage

func (*TaskQueueTask) Metadata

func (t *TaskQueueTask) Metadata() types.TaskMetadata

func (*TaskQueueTask) Retry

func (t *TaskQueueTask) Retry(ctx context.Context) error