redis

Documentation

Index

• type RedisPubSubClient
  • func (r *RedisPubSubClient) AckTaskCompletionProcessed(ctx context.Context, id interface{})
  • func (r *RedisPubSubClient) AckTaskProcessed(ctx context.Context, id interface{})
  • func (r *RedisPubSubClient) CreateConsumerGroupTasks(ctx context.Context)
  • func (r *RedisPubSubClient) CreateConsumerGroupTasksCompleted(ctx context.Context)
  • func (r *RedisPubSubClient) GetClient() *redis.Client
  • func (r *RedisPubSubClient) GetCompletedTasks(ctx context.Context, count int) ([]*core.TaskInstance, []interface{})
  • func (r *RedisPubSubClient) GetReadyToRunTasks(ctx context.Context, count int) ([]*core.TaskInstance, []interface{})
  • func (r *RedisPubSubClient) PublishTaskInstanceAsComplete(cxt context.Context, ti *core.TaskInstance, dag *core.DAG)
  • func (r *RedisPubSubClient) PublishTaskInstanceToRun(cxt context.Context, ti *core.TaskInstance, dag *core.DAG)

Types

type RedisPubSubClient

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

func (*RedisPubSubClient) AckTaskCompletionProcessed

func (r *RedisPubSubClient) AckTaskCompletionProcessed(ctx context.Context, id interface{})

func (*RedisPubSubClient) AckTaskProcessed

func (r *RedisPubSubClient) AckTaskProcessed(ctx context.Context, id interface{})

func (*RedisPubSubClient) CreateConsumerGroupTasks

func (r *RedisPubSubClient) CreateConsumerGroupTasks(ctx context.Context)

func (*RedisPubSubClient) CreateConsumerGroupTasksCompleted

func (r *RedisPubSubClient) CreateConsumerGroupTasksCompleted(ctx context.Context)

func (*RedisPubSubClient) GetClient

func (r *RedisPubSubClient) GetClient() *redis.Client

GetClient returns a redis.Client

func (*RedisPubSubClient) GetCompletedTasks

func (r *RedisPubSubClient) GetCompletedTasks(ctx context.Context, count int) ([]*core.TaskInstance, []interface{})

TODO: Ensure proper processing of messages and resend messages if they are kept for too long in XPENDING.

func (*RedisPubSubClient) GetReadyToRunTasks

func (r *RedisPubSubClient) GetReadyToRunTasks(ctx context.Context, count int) ([]*core.TaskInstance, []interface{})

TODO: Ensure proper processing of messages and resend messages if they are kept for too long in XPENDING.

func (*RedisPubSubClient) PublishTaskInstanceAsComplete

func (r *RedisPubSubClient) PublishTaskInstanceAsComplete(cxt context.Context, ti *core.TaskInstance, dag *core.DAG)

func (*RedisPubSubClient) PublishTaskInstanceToRun

func (r *RedisPubSubClient) PublishTaskInstanceToRun(cxt context.Context, ti *core.TaskInstance, dag *core.DAG)