bolt

Documentation

Index

• type DB
  • func New(path string, maxResultsLimit int) (DB, error)
  • func (db *DB) AddEvent(r storage.AddEventRequest) 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) DeleteEvent(r storage.DeleteEventRequest) error
  • func (db *DB) DeleteToken(r storage.DeleteTokenRequest) error
  • func (db *DB) GetAllEvents(r storage.GetAllEventsRequest) ([]models.Event, error)
  • func (db *DB) GetAllNamespaces(r storage.GetAllNamespacesRequest) ([]*models.Namespace, error)
  • func (db *DB) GetAllPipelines(r storage.GetAllPipelinesRequest) ([]*models.Pipeline, 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) GetEvent(r storage.GetEventRequest) (models.Event, 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) 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

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) AddEvent

func (db *DB) AddEvent(r storage.AddEventRequest) 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) DeleteEvent

func (db *DB) DeleteEvent(r storage.DeleteEventRequest) error

func (*DB) DeleteToken

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

func (*DB) GetAllEvents

func (db *DB) GetAllEvents(r storage.GetAllEventsRequest) ([]models.Event, 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) 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) GetEvent

func (db *DB) GetEvent(r storage.GetEventRequest) (models.Event, error)

GetEvent returns a single event 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) 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