storage

package

Go to main page

Versions in this module

v0

v0.6.2

Mar 6, 2024

v0.6.1

Nov 15, 2023

v0.6.0

Sep 18, 2023

v0.5.0

Apr 17, 2023

Changes in this version

+ func InsideTx(db *sqlx.DB, fn func(*sqlx.Tx) error) error

type DB

+ func (db *DB) DeleteGlobalExtensionRegistration(conn Queryable, name string) error

+ func (db *DB) DeletePipelineConfig(conn Queryable, namespace, pipeline string, version int64) error

+ func (db *DB) DeletePipelineDeployment(conn Queryable, namespace, pipeline string, id int64) error

+ func (db *DB) DeletePipelineExtensionSubscription(conn Queryable, namespace, pipeline, name, label string) error

+ func (db *DB) DeletePipelineMetadata(conn Queryable, namespace, id string) error

+ func (db *DB) DeletePipelineRun(conn Queryable, namespace, pipeline string, id int64) error

+ func (db *DB) DeletePipelineTaskRun(conn Queryable, namespace, pipeline string, run int64, id string) error

+ func (db *DB) DeleteTokenByHash(conn Queryable, hash string) error

+ func (db *DB) DeleteTokenByID(conn Queryable, id int64) error

+ func (db *DB) GetGlobalExtensionRegistration(conn Queryable, name string) (GlobalExtensionRegistration, error)

+ func (db *DB) GetLatestLivePipelineConfig(conn Queryable, namespace, pipeline string) (PipelineConfig, error)

+ func (db *DB) GetLatestPipelineConfig(conn Queryable, namespace, pipeline string) (PipelineConfig, error)

+ func (db *DB) GetLatestPipelineRun(conn Queryable, namespace, pipeline string) (PipelineRun, error)

+ func (db *DB) GetPipelineConfig(conn Queryable, namespace, pipeline string, version int64) (PipelineConfig, error)

+ func (db *DB) GetPipelineDeployment(conn Queryable, namespace, pipeline string, id int64) (PipelineDeployment, error)

+ func (db *DB) GetPipelineExtensionSubscription(conn Queryable, namespace, pipeline, name, label string) (PipelineExtensionSubscription, error)

+ func (db *DB) GetPipelineMetadata(conn Queryable, namespace, id string) (PipelineMetadata, error)

+ func (db *DB) GetPipelineRun(conn Queryable, namespace, pipeline string, id int64) (PipelineRun, error)

+ func (db *DB) GetPipelineTask(conn Queryable, namespace, pipeline string, version int64, id string) (PipelineTask, error)

+ func (db *DB) GetPipelineTaskRun(conn Queryable, namespace, pipeline string, run int64, id string) (PipelineTaskRun, error)

+ func (db *DB) GetTokenByHash(conn Queryable, hashStr string) (Token, error)

+ func (db *DB) GetTokenByID(conn Queryable, id int64) (Token, error)

+ func (db *DB) InsertGlobalExtensionRegistration(conn Queryable, tr *GlobalExtensionRegistration) error

+ func (db *DB) InsertPipelineConfig(conn Queryable, config *PipelineConfig) error

+ func (db *DB) InsertPipelineDeployment(conn Queryable, deployment *PipelineDeployment) error

+ func (db *DB) InsertPipelineExtensionSubscription(conn Queryable, sub *PipelineExtensionSubscription) error

+ func (db *DB) InsertPipelineMetadata(conn Queryable, metadata *PipelineMetadata) error

+ func (db *DB) InsertPipelineRun(conn Queryable, run *PipelineRun) error

+ func (db *DB) InsertPipelineTask(conn Queryable, task *PipelineTask) error

+ func (db *DB) InsertPipelineTaskRun(conn Queryable, taskRun *PipelineTaskRun) error

+ func (db *DB) ListGlobalExtensionRegistrations(conn Queryable, offset, limit int) ([]GlobalExtensionRegistration, error)

+ func (db *DB) ListPipelineConfigs(conn Queryable, offset, limit int, namespace, pipeline string) ([]PipelineConfig, error)

+ func (db *DB) ListPipelineDeployments(conn Queryable, offset, limit int, namespace, pipeline string) ([]PipelineDeployment, error)

+ func (db *DB) ListPipelineExtensionSubscriptions(conn Queryable, namespace, pipeline string) ([]PipelineExtensionSubscription, error)

+ func (db *DB) ListPipelineMetadata(conn Queryable, offset, limit int, namespace string) ([]PipelineMetadata, error)

+ func (db *DB) ListPipelineRuns(conn Queryable, offset, limit int, namespace, pipeline string) ([]PipelineRun, error)

+ func (db *DB) ListPipelineTaskRuns(conn Queryable, offset, limit int, namespace, pipeline string, run int64) ([]PipelineTaskRun, error)

+ func (db *DB) ListPipelineTasks(conn Queryable, namespace, pipeline string, version int64) ([]PipelineTask, error)

+ func (db *DB) ListRunningPipelineDeployments(conn Queryable, offset, limit int, namespace, pipeline string) ([]PipelineDeployment, error)

+ func (db *DB) UpdateGlobalExtensionRegistration(conn Queryable, name string, fields UpdatableGlobalExtensionRegistrationFields) error

+ func (db *DB) UpdatePipelineConfig(conn Queryable, namespace, pipeline string, version int64, ...) error

+ func (db *DB) UpdatePipelineDeployment(conn Queryable, namespace, pipeline string, id int64, ...) error

+ func (db *DB) UpdatePipelineExtensionSubscription(conn Queryable, namespace, pipeline, name, label string, ...) error

+ func (db *DB) UpdatePipelineMetadata(conn Queryable, namespace, id string, fields UpdatablePipelineMetadataFields) error

+ func (db *DB) UpdatePipelineRun(conn Queryable, namespace, pipeline string, id int64, ...) error

+ func (db *DB) UpdatePipelineTaskRun(conn Queryable, namespace, pipeline string, run int64, id string, ...) error

+ func (db *DB) UpdateSecretStoreGlobalKey(conn Queryable, key string, fields UpdatableSecretStoreGlobalKeyFields) error

+ type Event struct

+ Details string

+ Emitted int64

+ ID int64

+ Type string

+ type GlobalExtensionRegistration struct

+ Created int64

+ Image string

+ KeyID int64

+ Name string

+ RegistryAuth string

+ Status string

+ Variables string

+ type Namespace struct

+ Created int64

+ Description string

+ ID string

+ Modified int64

+ Name string

+ type ObjectStorePipelineKey struct

+ Created int64

+ Key string

+ Namespace string

+ Pipeline string

+ type ObjectStoreRunKey struct

+ Created int64

+ Key string

+ Namespace string

+ Pipeline string

+ Run int64

+ type PipelineConfig struct

+ Deprecated int64

+ Description string

+ Name string

+ Namespace string

+ Parallelism int64

+ Pipeline string

+ Registered int64

+ State string

+ Version int64

+ type PipelineDeployment struct

+ EndVersion int64

+ Ended int64

+ ID int64

+ Logs string

+ Namespace string

+ Pipeline string

+ StartVersion int64

+ Started int64

+ State string

+ Status string

+ StatusReason string

+ type PipelineExtensionSubscription struct

+ Label string

+ Name string

+ Namespace string

+ Pipeline string

+ Settings string

+ Status string

+ StatusReason string

+ type PipelineMetadata struct

+ Created int64

+ ID string

+ Modified int64

+ Namespace string

+ State string

+ type PipelineRun struct

+ Ended int64

+ ID int64

+ Initiator string

+ Namespace string

+ Pipeline string

+ PipelineConfigVersion int64

+ Started int64

+ State string

+ Status string

+ StatusReason string

+ StoreObjectsExpired bool

+ Variables string

+ type PipelineTask struct

+ Command string

+ DependsOn string

+ Description string

+ Entrypoint string

+ ID string

+ Image string

+ InjectAPIToken bool

+ Namespace string

+ Pipeline string

+ PipelineConfigVersion int64

+ RegistryAuth string

+ Variables string

+ type PipelineTaskRun struct

+ Created int64

+ Ended int64

+ ExitCode int64

+ ID string

+ LogsExpired bool

+ LogsRemoved bool

+ Namespace string

+ Pipeline string

+ Run int64

+ Started int64

+ State string

+ Status string

+ StatusReason string

+ Task string

+ TaskKind string

+ Variables string

+ type Queryable interface

+ Get func(interface{}, string, ...interface{}) error

+ GetContext func(context.Context, interface{}, string, ...interface{}) error

+ MustExec func(string, ...interface{}) sql.Result

+ MustExecContext func(context.Context, string, ...interface{}) sql.Result

+ NamedExec func(string, interface{}) (sql.Result, error)

+ NamedExecContext func(context.Context, string, interface{}) (sql.Result, error)

+ NamedQuery func(string, interface{}) (*sqlx.Rows, error)

+ PrepareNamed func(string) (*sqlx.NamedStmt, error)

+ PrepareNamedContext func(context.Context, string) (*sqlx.NamedStmt, error)

+ Preparex func(string) (*sqlx.Stmt, error)

+ PreparexContext func(context.Context, string) (*sqlx.Stmt, error)

+ QueryRow func(string, ...interface{}) *sql.Row

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ Select func(interface{}, string, ...interface{}) error

+ SelectContext func(context.Context, interface{}, string, ...interface{}) error

+ type SecretStoreGlobalKey struct

+ Created int64

+ Key string

+ Namespaces string

+ type SecretStorePipelineKey struct

+ Created int64

+ Key string

+ Namespace string

+ Pipeline string

+ type Token struct

+ Created int64

+ Disabled bool

+ Expires int64

+ Hash string

+ ID int64

+ Kind string

+ Metadata string

+ Namespaces string

+ type UpdatableGlobalExtensionRegistrationFields struct

+ Image *string

+ KeyID *int64

+ RegistryAuth *string

+ Status *string

+ Variables *string

+ type UpdatablePipelineConfigFields struct

+ Deprecated *int64

+ State *string

+ type UpdatablePipelineDeploymentFields struct

+ Ended *int64

+ Logs *string

+ State *string

+ Status *string

+ StatusReason *string

+ type UpdatablePipelineMetadataFields struct

+ Modified *int64

+ State *string

+ type UpdatablePipelineRunFields struct

+ Ended *int64

+ State *string

+ Status *string

+ StatusReason *string

+ StoreObjectsExpired *bool

+ Variables *string

+ type UpdatablePipelineTaskRunFields struct

+ Ended *int64

+ ExitCode *int64

+ LogsExpired *bool

+ LogsRemoved *bool

+ Started *int64

+ State *string

+ Status *string

+ StatusReason *string

+ Variables *string

+ type UpdatableSecretStoreGlobalKeyFields struct

+ Namespaces *string

+ type UpdateablePipelineExtensionSubscriptionFields struct

+ Settings *string

+ Status *string

+ StatusReason *string

v0.4.1

Nov 10, 2022

v0.4.0

Nov 10, 2022

v0.3.1

Oct 26, 2022

v0.3.0

Oct 13, 2022

Changes in this version

+ var ErrInternal = errors.New("storage: unknown db error")

+ type DB struct

+ func New(path string, maxResultsLimit int) (DB, error)

+ func (db *DB) DeleteCommonTaskRegistration(name string) error

+ func (db *DB) DeleteEvent(id int64) error

+ func (db *DB) DeleteNamespace(id string) error

+ func (db *DB) DeleteObjectStorePipelineKey(namespace, pipeline string, key string) error

+ func (db *DB) DeleteObjectStoreRunKey(namespace, pipeline string, run int64, key string) error

+ func (db *DB) DeletePipeline(namespace, id string) error

+ func (db *DB) DeleteRun(namespace, pipeline string, id int64) error

+ func (db *DB) DeleteSecretStoreGlobalKey(key string) error

+ func (db *DB) DeleteSecretStorePipelineKey(namespace, pipeline string, key string) error

+ func (db *DB) DeleteTaskRun(namespace, pipeline string, run int64, id string) error

+ func (db *DB) DeleteToken(hash string) error

+ func (db *DB) DeleteTriggerRegistration(name string) error

+ func (db *DB) DisableToken(hashStr string) error

+ func (db *DB) EnableToken(hashStr string) error

+ func (db *DB) GetCommonTaskRegistration(name string) (models.CommonTaskRegistration, error)

+ func (db *DB) GetEvent(id int64) (models.Event, error)

+ func (db *DB) GetNamespace(id string) (models.Namespace, error)

+ func (db *DB) GetPipeline(conn qb.BaseRunner, namespace, pipeline string) (models.Pipeline, error)

+ func (db *DB) GetRun(namespace, pipeline string, run int64) (models.Run, error)

+ func (db *DB) GetSecretStoreGlobalKey(key string) (models.SecretStoreKey, error)

+ func (db *DB) GetSecretStorePipelineKey(namespace, pipeline, key string) (models.SecretStoreKey, error)

+ func (db *DB) GetTaskRun(namespace, pipeline string, run int64, taskRun string) (models.TaskRun, error)

+ func (db *DB) GetToken(hashStr string) (models.Token, error)

+ func (db *DB) GetTriggerRegistration(name string) (models.TriggerRegistration, error)

+ func (db *DB) InsertCommonTaskRegistration(tr *models.CommonTaskRegistration) error

+ func (db *DB) InsertEvent(event *models.Event) (int64, error)

+ func (db *DB) InsertNamespace(namespace *models.Namespace) error

+ func (db *DB) InsertObjectStorePipelineKey(namespace, pipeline string, objectKey *models.ObjectStoreKey) error

+ func (db *DB) InsertObjectStoreRunKey(namespace, pipeline string, run int64, objectKey *models.ObjectStoreKey) error

+ func (db *DB) InsertPipeline(pipeline *models.Pipeline) error

+ func (db *DB) InsertRun(run *models.Run) (int64, error)

+ func (db *DB) InsertSecretStoreGlobalKey(secretKey *models.SecretStoreKey, force bool) error

+ func (db *DB) InsertSecretStorePipelineKey(namespace, pipeline string, secretKey *models.SecretStoreKey, force bool) error

+ func (db *DB) InsertTaskRun(taskRun *models.TaskRun) error

+ func (db *DB) InsertToken(tr *models.Token) error

+ func (db *DB) InsertTriggerRegistration(tr *models.TriggerRegistration) error

+ func (db *DB) ListCommonTaskRegistrations(offset, limit int) ([]models.CommonTaskRegistration, error)

+ func (db *DB) ListCommonTaskSettings(conn qb.BaseRunner, namespace, pipeline string) ([]models.PipelineCommonTaskSettings, error)

+ func (db *DB) ListEvents(offset, limit int, reverse bool) ([]models.Event, error)

+ func (db *DB) ListNamespaces(offset, limit int) ([]models.Namespace, error)

+ func (db *DB) ListObjectStorePipelineKeys(namespace, pipeline string) ([]models.ObjectStoreKey, error)

+ func (db *DB) ListObjectStoreRunKeys(namespace, pipeline string, run int64) ([]models.ObjectStoreKey, error)

+ func (db *DB) ListPipelines(offset, limit int, namespace string) ([]models.Pipeline, error)

+ func (db *DB) ListRuns(conn qb.BaseRunner, offset, limit int, namespace, pipeline string) ([]models.Run, error)

+ func (db *DB) ListSecretStoreGlobalKeys() ([]models.SecretStoreKey, error)

+ func (db *DB) ListSecretStorePipelineKeys(namespace, pipeline string) ([]models.SecretStoreKey, error)

+ func (db *DB) ListTaskRuns(offset, limit int, namespace, pipeline string, run int64) ([]models.TaskRun, error)

+ func (db *DB) ListTasks(conn qb.BaseRunner, namespace, pipeline string) ([]models.CustomTask, error)

+ func (db *DB) ListTokens(offset, limit int) ([]models.Token, error)

+ func (db *DB) ListTriggerRegistrations(offset, limit int) ([]models.TriggerRegistration, error)

+ func (db *DB) ListTriggerSettings(conn qb.BaseRunner, namespace, pipeline string) ([]models.PipelineTriggerSettings, error)

+ func (db *DB) UpdateCommonTaskRegistration(name string, fields UpdatableCommonTaskRegistrationFields) error

+ func (db *DB) UpdateNamespace(id string, fields UpdatableNamespaceFields) error

+ func (db *DB) UpdatePipeline(namespace, id string, fields UpdatablePipelineFields) error

+ func (db *DB) UpdateRun(namespace, pipeline string, run int64, fields UpdatableRunFields) error

+ func (db *DB) UpdateTaskRun(taskRun *models.TaskRun, fields UpdatableTaskRunFields) error

+ func (db *DB) UpdateTriggerRegistration(name string, fields UpdatableTriggerRegistrationFields) error

+ type UpdatableCommonTaskRegistrationFields struct

+ Documentation *string

+ Image *string

+ RegistryAuth *models.RegistryAuth

+ Status *models.CommonTaskStatus

+ Variables *map[string]string

+ type UpdatableNamespaceFields struct

+ Description *string

+ Modified *int64

+ Name *string

+ type UpdatablePipelineFields struct

+ CommonTasks *map[string]models.PipelineCommonTaskSettings

+ Description *string

+ Errors *[]models.PipelineError

+ Modified *int64

+ Name *string

+ Parallelism *int64

+ State *models.PipelineState

+ Tasks *map[string]models.CustomTask

+ Triggers *map[string]models.PipelineTriggerSettings

+ type UpdatableRunFields struct

+ Ended *int64

+ State *models.RunState

+ Status *models.RunStatus

+ StatusReason *models.RunStatusReason

+ StoreObjectsExpired *bool

+ TaskRuns *[]string

+ Variables *[]models.Variable

+ type UpdatableTaskRunFields struct

+ Ended *int64

+ ExitCode *int64

+ LogsExpired *bool

+ LogsRemoved *bool

+ Started *int64

+ State *models.TaskRunState

+ Status *models.TaskRunStatus

+ StatusReason *models.TaskRunStatusReason

+ Variables *[]models.Variable

+ type UpdatableTriggerRegistrationFields struct

+ Image *string

+ RegistryAuth *models.RegistryAuth

+ Status *models.TriggerStatus

+ Variables *map[string]string

v0.2.0-beta

Apr 25, 2022

v0.2.0-alpha

Oct 4, 2022

v0.1.0

Feb 22, 2022

Changes in this version

+ type AddEventRequest struct

+ Event models.Event

+ type DeleteEventRequest struct

+ ID int64

type Engine

+ AddEvent func(r AddEventRequest) error

+ DeleteEvent func(r DeleteEventRequest) error

+ GetAllEvents func(r GetAllEventsRequest) ([]models.Event, error)

+ GetEvent func(r GetEventRequest) (models.Event, error)

+ type GetAllEventsRequest struct

+ Limit int

+ Offset int

+ Reverse bool

+ type GetEventRequest struct

+ ID int64

v0.1.0-alpha

Sep 27, 2022

v0.0.3

Jan 28, 2022

v0.0.2

Jan 7, 2022

v0.0.1

Jan 5, 2022

Changes in this version

+ var ErrEntityExists = errors.New("storage: entity already exists")

+ var ErrEntityNotFound = errors.New("storage: entity not found")

+ var ErrPreconditionFailure = errors.New("storage: parameters did not pass validation")

+ type AddDockerRegistryAuthRequest struct

+ DockerRegistryAuth *models.DockerRegistryAuth

+ type AddNamespaceRequest struct

+ Namespace *models.Namespace

+ type AddPipelineRequest struct

+ Pipeline *models.Pipeline

+ type AddRunRequest struct

+ Run *models.Run

+ type AddTaskRunRequest struct

+ TaskRun *models.TaskRun

+ type AddTokenRequest struct

+ Token *models.Token

+ type AddTriggerEventRequest struct

+ Event *models.TriggerEvent

+ type DeleteRunRequest struct

+ ID int64

+ NamespaceID string

+ PipelineID string

+ type DeleteTokenRequest struct

+ Hash string

+ type Engine interface

+ AddDockerRegistryAuth func(r AddDockerRegistryAuthRequest) error

+ AddNamespace func(r AddNamespaceRequest) error

+ AddPipeline func(r AddPipelineRequest) error

+ AddRun func(r AddRunRequest) error

+ AddTaskRun func(r AddTaskRunRequest) error

+ AddToken func(r AddTokenRequest) error

+ AddTriggerEvent func(r AddTriggerEventRequest) error

+ DeleteToken func(r DeleteTokenRequest) error

+ GetAllDockerRegistryAuths func(r GetAllDockerRegistryAuthsRequest) ([]*models.DockerRegistryAuth, error)

+ GetAllNamespaces func(r GetAllNamespacesRequest) ([]*models.Namespace, error)

+ GetAllPipelines func(r GetAllPipelinesRequest) ([]*models.Pipeline, error)

+ GetAllRunRegistrations func(r GetAllRunRegistrationsRequest) (map[RunRegistryKey]struct{}, error)

+ GetAllRuns func(r GetAllRunsRequest) ([]*models.Run, error)

+ GetAllTaskRuns func(r GetAllTaskRunsRequest) ([]*models.TaskRun, error)

+ GetAllTokens func(r GetAllTokensRequest) ([]*models.Token, error)

+ GetAllTriggerEvents func(r GetAllTriggerEventsRequest) ([]*models.TriggerEvent, error)

+ GetDockerRegistryAuth func(r GetDockerRegistryAuthRequest) (*models.DockerRegistryAuth, error)

+ GetNamespace func(r GetNamespaceRequest) (*models.Namespace, error)

+ GetPipeline func(r GetPipelineRequest) (*models.Pipeline, error)

+ GetRun func(r GetRunRequest) (*models.Run, error)

+ GetTaskRun func(r GetTaskRunRequest) (*models.TaskRun, error)

+ GetToken func(r GetTokenRequest) (*models.Token, error)

+ GetTriggerEvent func(r GetTriggerEventRequest) (*models.TriggerEvent, error)

+ RegisterRun func(r RegisterRunRequest) error

+ RegistrationExists func(r RegistrationExistsRequest) bool

+ RemoveDockerRegistryAuth func(r RemoveDockerRegistryAuthRequest) error

+ UnregisterRun func(r UnregisterRunRequest) error

+ UpdateNamespace func(r UpdateNamespaceRequest) error

+ UpdatePipeline func(r UpdatePipelineRequest) error

+ UpdateRun func(r UpdateRunRequest) error

+ UpdateTaskRun func(r UpdateTaskRunRequest) error

+ UpdateTriggerEvent func(r UpdateTriggerEventRequest) error

+ type EngineType string

+ const StorageEngineBoltDB

+ type GetAllDockerRegistryAuthsRequest struct

+ type GetAllNamespacesRequest struct

+ Limit int

+ Offset int

+ type GetAllPipelinesRequest struct

+ Limit int

+ NamespaceID string

+ Offset int

+ type GetAllRunRegistrationsRequest struct

+ type GetAllRunsRequest struct

+ Limit int

+ NamespaceID string

+ Offset int

+ PipelineID string

+ type GetAllTaskRunsRequest struct

+ NamespaceID string

+ PipelineID string

+ RunID int64

+ type GetAllTokensRequest struct

+ Limit int

+ Namespaces []string

+ Offset int

+ type GetAllTriggerEventsRequest struct

+ Limit int

+ NamespaceID string

+ Offset int

+ PipelineID string

+ PipelineTriggerLabel string

+ type GetDockerRegistryAuthRequest struct

+ Registry string

+ type GetNamespaceRequest struct

+ ID string

+ type GetPipelineRequest struct

+ ID string

+ NamespaceID string

+ type GetRunRequest struct

+ ID int64

+ NamespaceID string

+ PipelineID string

+ type GetTaskRunRequest struct

+ ID string

+ NamespaceID string

+ PipelineID string

+ RunID int64

+ type GetTokenRequest struct

+ Hash string

+ type GetTriggerEventRequest struct

+ ID int64

+ NamespaceID string

+ PipelineID string

+ PipelineTriggerLabel string

+ type RegisterRunRequest struct

+ Namespace string

+ Pipeline string

+ Run int64

+ type RegistrationExistsRequest struct

+ Namespace string

+ Pipeline string

+ Run int64

+ type RemoveDockerRegistryAuthRequest struct

+ Registry string

+ type RunRegistryKey struct

+ Namespace string

+ Pipeline string

+ Run int64

+ type UnregisterRunRequest struct

+ Namespace string

+ Pipeline string

+ Run int64

+ type UpdateNamespaceRequest struct

+ Namespace *models.Namespace

+ type UpdatePipelineRequest struct

+ Pipeline *models.Pipeline

+ type UpdateRunRequest struct

+ Run *models.Run

+ type UpdateTaskRunRequest struct

+ TaskRun *models.TaskRun

+ type UpdateTriggerEventRequest struct

+ Event *models.TriggerEvent

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL