db

Documentation

Index

• type ArchiveDeleteRequest
• type Client
  • func (client *Client) ArchivePipeline(pipelineID uint64) (_ uint64, err error)
  • func (client *Client) CreatePipelineArchive(archive *spec.PipelineArchive, ops ...dbclient.SessionOption) error
  • func (client *Client) DeletePipelineArchives(req ArchiveDeleteRequest, ops ...dbclient.SessionOption) error
  • func (client *Client) GetPipelineArchiveByPipelineID(pipelineID uint64, ops ...dbclient.SessionOption) (spec.PipelineArchive, bool, error)
  • func (client *Client) GetPipelineFromArchive(pipelineID uint64, ops ...dbclient.SessionOption) (spec.Pipeline, bool, error)
  • func (client *Client) GetPipelineIncludeArchived(pipelineID uint64, ops ...dbclient.SessionOption) (spec.Pipeline, bool, bool, error)
  • func (client *Client) GetPipelineTasksFromArchive(pipelineID uint64, ops ...dbclient.SessionOption) ([]spec.PipelineTask, error)
  • func (client *Client) GetPipelineTasksIncludeArchived(pipelineID uint64, ops ...dbclient.SessionOption) ([]spec.PipelineTask, bool, error)

Types

type ArchiveDeleteRequest

type ArchiveDeleteRequest struct {
	Statuses       []string
	NotStatuses    []string
	EndTimeCreated time.Time
}

type Client

type Client struct {
	dbclient.Client
}

func (*Client) ArchivePipeline

func (client *Client) ArchivePipeline(pipelineID uint64) (_ uint64, err error)

func (*Client) CreatePipelineArchive

func (client *Client) CreatePipelineArchive(archive *spec.PipelineArchive, ops ...dbclient.SessionOption) error

func (*Client) DeletePipelineArchives

func (client *Client) DeletePipelineArchives(req ArchiveDeleteRequest, ops ...dbclient.SessionOption) error

func (*Client) GetPipelineArchiveByPipelineID

func (client *Client) GetPipelineArchiveByPipelineID(pipelineID uint64, ops ...dbclient.SessionOption) (spec.PipelineArchive, bool, error)

func (*Client) GetPipelineFromArchive

func (client *Client) GetPipelineFromArchive(pipelineID uint64, ops ...dbclient.SessionOption) (spec.Pipeline, bool, error)

func (*Client) GetPipelineIncludeArchived

func (client *Client) GetPipelineIncludeArchived(pipelineID uint64, ops ...dbclient.SessionOption) (spec.Pipeline, bool, bool, error)

GetPipelineIncludeArchived return: pipeline, exist, findFromArchive, error

func (*Client) GetPipelineTasksFromArchive

func (client *Client) GetPipelineTasksFromArchive(pipelineID uint64, ops ...dbclient.SessionOption) ([]spec.PipelineTask, error)

func (*Client) GetPipelineTasksIncludeArchived

func (client *Client) GetPipelineTasksIncludeArchived(pipelineID uint64, ops ...dbclient.SessionOption) ([]spec.PipelineTask, bool, error)

GetPipelineTasksIncludeArchived return: tasks, findFromArchive, error