redis

type Client interface {
	GetPipelines(targets []interface{}) error
	GetPipeline(uid string, target interface{}) error
	SavePipeline(uid string, data interface{}) (*PipelineLease, error)
	CreatePipeline(uid, owner string, data interface{}) (*PipelineLease, error)

	AcquireLease(owner, pipelineUid string) (*PipelineLease, error)
	ExtendLease(owner, pipelineUid string) (*PipelineLease, error)
	TerminateLease(pipelineUid string) error

	SaveArtifact(pipelineUid, artifactName string, artifact []byte, retention time.Duration) error
	GetArtifact(pipelineUid, artifactName string) ([]byte, error)
	ListArtifacts(pipelineUid string) ([]string, error)
	GetArtifacts(pipelineUid string) (map[string][]byte, error)
}

type PipelineLease struct {
	PipelineUid string    `json:"pipelineUid"`
	Owner       string    `json:"owner"`
	Acquired    time.Time `json:"acquired"`
	Expires     time.Time `json:"expires"`
}

type RedisClient interface {
	TxPipeline() goredis.Pipeliner
	LRange(ctx context.Context, key string, start, stop int64) *goredis.StringSliceCmd
	Get(ctx context.Context, key string) *goredis.StringCmd
	Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *goredis.StatusCmd
	LPush(ctx context.Context, key string, values ...interface{}) *goredis.IntCmd
	Expire(ctx context.Context, key string, expiration time.Duration) *goredis.BoolCmd
	Del(ctx context.Context, keys ...string) *goredis.IntCmd
	HSet(ctx context.Context, key string, values ...interface{}) *goredis.IntCmd
	HGet(ctx context.Context, key, field string) *goredis.StringCmd
	HKeys(ctx context.Context, key string) *goredis.StringSliceCmd
}

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