bolt

Documentation

Index

• type DB
  • func New(path string, maxResultsLimit int) (DB, error)
  • func (db *DB) AddDockerRegistryAuth(r storage.AddDockerRegistryAuthRequest) error
  • func (db *DB) AddNamespace(r storage.AddNamespaceRequest) error
  • func (db *DB) AddPipeline(r storage.AddPipelineRequest) error
  • func (db *DB) AddRun(r storage.AddRunRequest) error
  • func (db *DB) AddTaskRun(r storage.AddTaskRunRequest) error
  • func (db *DB) AddToken(r storage.AddTokenRequest) error
  • func (db *DB) AddTriggerEvent(r storage.AddTriggerEventRequest) error
  • func (db *DB) DeleteToken(r storage.DeleteTokenRequest) error
  • func (db *DB) GetAllDockerRegistryAuths(r storage.GetAllDockerRegistryAuthsRequest) ([]*models.DockerRegistryAuth, error)
  • func (db *DB) GetAllNamespaces(r storage.GetAllNamespacesRequest) ([]*models.Namespace, error)
  • func (db *DB) GetAllPipelines(r storage.GetAllPipelinesRequest) ([]*models.Pipeline, error)
  • func (db *DB) GetAllRunRegistrations(r storage.GetAllRunRegistrationsRequest) (map[storage.RunRegistryKey]struct{}, error)
  • func (db *DB) GetAllRuns(r storage.GetAllRunsRequest) ([]*models.Run, error)
  • func (db *DB) GetAllTaskRuns(r storage.GetAllTaskRunsRequest) ([]*models.TaskRun, error)
  • func (db *DB) GetAllTokens(r storage.GetAllTokensRequest) ([]*models.Token, error)
  • func (db *DB) GetAllTriggerEvents(r storage.GetAllTriggerEventsRequest) ([]*models.TriggerEvent, error)
  • func (db *DB) GetDockerRegistryAuth(r storage.GetDockerRegistryAuthRequest) (*models.DockerRegistryAuth, error)
  • func (db *DB) GetNamespace(r storage.GetNamespaceRequest) (*models.Namespace, error)
  • func (db *DB) GetPipeline(r storage.GetPipelineRequest) (*models.Pipeline, error)
  • func (db *DB) GetRun(r storage.GetRunRequest) (*models.Run, error)
  • func (db *DB) GetTaskRun(r storage.GetTaskRunRequest) (*models.TaskRun, error)
  • func (db *DB) GetToken(r storage.GetTokenRequest) (*models.Token, error)
  • func (db *DB) GetTriggerEvent(r storage.GetTriggerEventRequest) (*models.TriggerEvent, error)
  • func (db *DB) RegisterRun(r storage.RegisterRunRequest) error
  • func (db *DB) RegistrationExists(r storage.RegistrationExistsRequest) bool
  • func (db *DB) RemoveDockerRegistryAuth(r storage.RemoveDockerRegistryAuthRequest) error
  • func (db *DB) UnregisterRun(r storage.UnregisterRunRequest) error
  • func (db *DB) UpdateNamespace(r storage.UpdateNamespaceRequest) error
  • func (db *DB) UpdatePipeline(r storage.UpdatePipelineRequest) error
  • func (db *DB) UpdateRun(r storage.UpdateRunRequest) error
  • func (db *DB) UpdateTaskRun(r storage.UpdateTaskRunRequest) error
  • func (db *DB) UpdateTriggerEvent(r storage.UpdateTriggerEventRequest) error

Types

type DB

type DB struct {
	*storm.DB
	// contains filtered or unexported fields
}

DB is a representation of the bolt datastore

func New

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

New creates a new boltdb with given settings

func (*DB) AddDockerRegistryAuth

func (db *DB) AddDockerRegistryAuth(r storage.AddDockerRegistryAuthRequest) error

func (*DB) AddNamespace

func (db *DB) AddNamespace(r storage.AddNamespaceRequest) error

func (*DB) AddPipeline

func (db *DB) AddPipeline(r storage.AddPipelineRequest) error

func (*DB) AddRun

func (db *DB) AddRun(r storage.AddRunRequest) error

func (*DB) AddTaskRun

func (db *DB) AddTaskRun(r storage.AddTaskRunRequest) error

func (*DB) AddToken

func (db *DB) AddToken(r storage.AddTokenRequest) error

func (*DB) AddTriggerEvent

func (db *DB) AddTriggerEvent(r storage.AddTriggerEventRequest) error

func (*DB) DeleteToken

func (db *DB) DeleteToken(r storage.DeleteTokenRequest) error

func (*DB) GetAllDockerRegistryAuths

func (db *DB) GetAllDockerRegistryAuths(r storage.GetAllDockerRegistryAuthsRequest) ([]*models.DockerRegistryAuth, error)

func (*DB) GetAllNamespaces

func (db *DB) GetAllNamespaces(r storage.GetAllNamespacesRequest) ([]*models.Namespace, error)

func (*DB) GetAllPipelines

func (db *DB) GetAllPipelines(r storage.GetAllPipelinesRequest) ([]*models.Pipeline, error)

GetAllPipelines returns all pipelines with given parameters.

func (*DB) GetAllRunRegistrations

func (db *DB) GetAllRunRegistrations(r storage.GetAllRunRegistrationsRequest) (map[storage.RunRegistryKey]struct{}, error)

func (*DB) GetAllRuns

func (db *DB) GetAllRuns(r storage.GetAllRunsRequest) ([]*models.Run, error)

func (*DB) GetAllTaskRuns

func (db *DB) GetAllTaskRuns(r storage.GetAllTaskRunsRequest) ([]*models.TaskRun, error)

func (*DB) GetAllTokens

func (db *DB) GetAllTokens(r storage.GetAllTokensRequest) ([]*models.Token, error)

func (*DB) GetAllTriggerEvents

func (db *DB) GetAllTriggerEvents(r storage.GetAllTriggerEventsRequest) ([]*models.TriggerEvent, error)

func (*DB) GetDockerRegistryAuth

func (db *DB) GetDockerRegistryAuth(r storage.GetDockerRegistryAuthRequest) (*models.DockerRegistryAuth, error)

GetDockerRegistryAuth returns a single dockerregistryauth by id.

func (*DB) GetNamespace

func (db *DB) GetNamespace(r storage.GetNamespaceRequest) (*models.Namespace, error)

GetNamespace returns a single namespace by id.

func (*DB) GetPipeline

func (db *DB) GetPipeline(r storage.GetPipelineRequest) (*models.Pipeline, error)

GetPipeline returns a single pipeline by id.

func (*DB) GetRun

func (db *DB) GetRun(r storage.GetRunRequest) (*models.Run, error)

GetRun returns a single Run by id

func (*DB) GetTaskRun

func (db *DB) GetTaskRun(r storage.GetTaskRunRequest) (*models.TaskRun, error)

GetTaskRun returns a single TaskRun by id

func (*DB) GetToken

func (db *DB) GetToken(r storage.GetTokenRequest) (*models.Token, error)

GetToken returns a single token by hash.

func (*DB) GetTriggerEvent

func (db *DB) GetTriggerEvent(r storage.GetTriggerEventRequest) (*models.TriggerEvent, error)

GetTriggerEvent returns a single event by id

func (*DB) RegisterRun

func (db *DB) RegisterRun(r storage.RegisterRunRequest) error

func (*DB) RegistrationExists

func (db *DB) RegistrationExists(r storage.RegistrationExistsRequest) bool

func (*DB) RemoveDockerRegistryAuth

func (db *DB) RemoveDockerRegistryAuth(r storage.RemoveDockerRegistryAuthRequest) error

func (*DB) UnregisterRun

func (db *DB) UnregisterRun(r storage.UnregisterRunRequest) error

func (*DB) UpdateNamespace

func (db *DB) UpdateNamespace(r storage.UpdateNamespaceRequest) error

func (*DB) UpdatePipeline

func (db *DB) UpdatePipeline(r storage.UpdatePipelineRequest) error

func (*DB) UpdateRun

func (db *DB) UpdateRun(r storage.UpdateRunRequest) error

func (*DB) UpdateTaskRun

func (db *DB) UpdateTaskRun(r storage.UpdateTaskRunRequest) error

func (*DB) UpdateTriggerEvent

func (db *DB) UpdateTriggerEvent(r storage.UpdateTriggerEventRequest) error