Documentation ¶
Index ¶
- type RedisDataStoreClient
- func (r *RedisDataStoreClient) AddDag(ctx context.Context, dag *core.DAG)
- func (r *RedisDataStoreClient) AddDagRun(ctx context.Context, dag *core.DAG, schTime time.Time)
- func (r *RedisDataStoreClient) AddOrUpdateTaskInstance(ctx context.Context, taskInstance *core.TaskInstance, dag *core.DAG)
- func (r *RedisDataStoreClient) AddTask(ctx context.Context, task core.TaskInterface)
- func (r *RedisDataStoreClient) GetAllDags(ctx context.Context) chan *core.DAG
- func (r *RedisDataStoreClient) GetClient() *redis.Client
- func (r *RedisDataStoreClient) GetDag(ctx context.Context, dagName string) *core.DAG
- func (r *RedisDataStoreClient) GetDagLastRun(ctx context.Context, dagName string) (time.Time, bool)
- func (r *RedisDataStoreClient) GetTaskInstances(ctx context.Context, dag *core.DAG, dagRunTime time.Time) map[string]*core.TaskInstance
- func (r *RedisDataStoreClient) UpdateDagRunToComplete(ctx context.Context, dag *core.DAG, schTime time.Time)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisDataStoreClient ¶
type RedisDataStoreClient struct {
// contains filtered or unexported fields
}
func (*RedisDataStoreClient) AddDag ¶
func (r *RedisDataStoreClient) AddDag(ctx context.Context, dag *core.DAG)
TODO: use ctx passed in methods which interact with GetClient TODO: Use Redis Transactions here
func (*RedisDataStoreClient) AddOrUpdateTaskInstance ¶
func (r *RedisDataStoreClient) AddOrUpdateTaskInstance(ctx context.Context, taskInstance *core.TaskInstance, dag *core.DAG)
func (*RedisDataStoreClient) AddTask ¶
func (r *RedisDataStoreClient) AddTask(ctx context.Context, task core.TaskInterface)
func (*RedisDataStoreClient) GetAllDags ¶
func (r *RedisDataStoreClient) GetAllDags(ctx context.Context) chan *core.DAG
func (*RedisDataStoreClient) GetClient ¶
func (r *RedisDataStoreClient) GetClient() *redis.Client
GetClient returns a redis.Client
func (*RedisDataStoreClient) GetDagLastRun ¶
func (*RedisDataStoreClient) GetTaskInstances ¶
func (r *RedisDataStoreClient) GetTaskInstances(ctx context.Context, dag *core.DAG, dagRunTime time.Time) map[string]*core.TaskInstance
func (*RedisDataStoreClient) UpdateDagRunToComplete ¶
Click to show internal directories.
Click to hide internal directories.