cockroachdb_store

Documentation

Index

• func NewCockroachdbStore(uri string, config *gorm.Config, opts ...CockroachdbStoreOpt) pkg.StoreInterface
• type CockroachdbStore
  • func (c *CockroachdbStore) DeleteCompletedTaskDefinitions() error
  • func (c *CockroachdbStore) DeleteCompletedTaskInstances() error
  • func (c *CockroachdbStore) DeleteTaskDefinition(id *uuid.UUID) error
  • func (c *CockroachdbStore) DeleteTaskDefinitions(ids []*uuid.UUID) error
  • func (c *CockroachdbStore) DeleteTaskDefinitionsByMetadata(metadataQuery interface{}) error
  • func (c *CockroachdbStore) DeleteTaskInstance(id *uuid.UUID) error
  • func (c *CockroachdbStore) GetTaskDefinition(id *uuid.UUID) (pkg.TaskDefinition, error)
  • func (c *CockroachdbStore) GetTaskDefinitions(ids []*uuid.UUID) ([]pkg.TaskDefinition, error)
  • func (c *CockroachdbStore) GetTaskDefinitionsToSchedule(limit time.Time) ([]pkg.TaskDefinition, error)
  • func (c *CockroachdbStore) GetTaskInstance(id *uuid.UUID) (pkg.TaskInstance, error)
  • func (c *CockroachdbStore) GetTaskInstancesToRun(limit time.Time) ([]pkg.TaskInstance, error)
  • func (c *CockroachdbStore) Initialize() (err error)
  • func (c *CockroachdbStore) ListCompletedTaskDefinitions() ([]pkg.TaskDefinition, error)
  • func (c *CockroachdbStore) ListCompletedTaskInstances() ([]pkg.TaskInstance, error)
  • func (c *CockroachdbStore) ListTaskDefinitions(offset, limit int, metadataQuery interface{}) ([]pkg.TaskDefinition, error)
  • func (c *CockroachdbStore) ListTaskInstances(offset, limit int) ([]pkg.TaskInstance, error)
  • func (c *CockroachdbStore) MarkTaskInstanceComplete(taskInstance pkg.TaskInstance) error
  • func (c *CockroachdbStore) UpsertTaskDefinition(taskDefinition pkg.TaskDefinition) error
  • func (c *CockroachdbStore) UpsertTaskInstance(taskInstance pkg.TaskInstance) error
• type CockroachdbStoreOpt
  • func WithConnectionSettings(maxIdleConns, maxOpenConns int, connMaxLifetime time.Duration) CockroachdbStoreOpt

Functions

func NewCockroachdbStore

func NewCockroachdbStore(uri string, config *gorm.Config, opts ...CockroachdbStoreOpt) pkg.StoreInterface

Types

type CockroachdbStore

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

func (*CockroachdbStore) DeleteCompletedTaskDefinitions

func (c *CockroachdbStore) DeleteCompletedTaskDefinitions() error

func (*CockroachdbStore) DeleteCompletedTaskInstances

func (c *CockroachdbStore) DeleteCompletedTaskInstances() error

func (*CockroachdbStore) DeleteTaskDefinition

func (c *CockroachdbStore) DeleteTaskDefinition(id *uuid.UUID) error

func (*CockroachdbStore) DeleteTaskDefinitions

func (c *CockroachdbStore) DeleteTaskDefinitions(ids []*uuid.UUID) error

func (*CockroachdbStore) DeleteTaskDefinitionsByMetadata

func (c *CockroachdbStore) DeleteTaskDefinitionsByMetadata(metadataQuery interface{}) error

func (*CockroachdbStore) DeleteTaskInstance

func (c *CockroachdbStore) DeleteTaskInstance(id *uuid.UUID) error

func (*CockroachdbStore) GetTaskDefinition

func (c *CockroachdbStore) GetTaskDefinition(id *uuid.UUID) (pkg.TaskDefinition, error)

func (*CockroachdbStore) GetTaskDefinitions

func (c *CockroachdbStore) GetTaskDefinitions(ids []*uuid.UUID) ([]pkg.TaskDefinition, error)

func (*CockroachdbStore) GetTaskDefinitionsToSchedule

func (c *CockroachdbStore) GetTaskDefinitionsToSchedule(limit time.Time) ([]pkg.TaskDefinition, error)

func (*CockroachdbStore) GetTaskInstance

func (c *CockroachdbStore) GetTaskInstance(id *uuid.UUID) (pkg.TaskInstance, error)

func (*CockroachdbStore) GetTaskInstancesToRun

func (c *CockroachdbStore) GetTaskInstancesToRun(limit time.Time) ([]pkg.TaskInstance, error)

func (*CockroachdbStore) Initialize

func (c *CockroachdbStore) Initialize() (err error)

func (*CockroachdbStore) ListCompletedTaskDefinitions

func (c *CockroachdbStore) ListCompletedTaskDefinitions() ([]pkg.TaskDefinition, error)

func (*CockroachdbStore) ListCompletedTaskInstances

func (c *CockroachdbStore) ListCompletedTaskInstances() ([]pkg.TaskInstance, error)

func (*CockroachdbStore) ListTaskDefinitions

func (c *CockroachdbStore) ListTaskDefinitions(offset, limit int, metadataQuery interface{}) ([]pkg.TaskDefinition, error)

func (*CockroachdbStore) ListTaskInstances

func (c *CockroachdbStore) ListTaskInstances(offset, limit int) ([]pkg.TaskInstance, error)

func (*CockroachdbStore) MarkTaskInstanceComplete

func (c *CockroachdbStore) MarkTaskInstanceComplete(taskInstance pkg.TaskInstance) error

func (*CockroachdbStore) UpsertTaskDefinition

func (c *CockroachdbStore) UpsertTaskDefinition(taskDefinition pkg.TaskDefinition) error

func (*CockroachdbStore) UpsertTaskInstance

func (c *CockroachdbStore) UpsertTaskInstance(taskInstance pkg.TaskInstance) error

type CockroachdbStoreOpt

type CockroachdbStoreOpt func(*CockroachdbStore)

func WithConnectionSettings

func WithConnectionSettings(maxIdleConns, maxOpenConns int, connMaxLifetime time.Duration) CockroachdbStoreOpt