store

Documentation

Index

• type Store
  • func New(location string, log commons.Logger) (*Store, error)
  • func (s *Store) Close()
  • func (s *Store) CopyTo(w io.Writer) (int, error)
  • func (s *Store) CreateAsset(a *models.Asset)
  • func (s *Store) CreateEnv(xp *models.Env)
  • func (s *Store) CreatePipeline(p *models.Pipeline)
  • func (s *Store) CreateXProcessor(xp *models.XProcessor)
  • func (s *Store) DeleteAsset(a *models.Asset)
  • func (s *Store) DeleteEnv(p *models.Env)
  • func (s *Store) DeletePipeline(p *models.Pipeline)
  • func (s *Store) DeleteXProcessor(p *models.XProcessor)
  • func (s *Store) FindAssetsByPipelineUUID(uuid string) ([]models.Asset, error)
  • func (s *Store) FindEnvs() []models.Env
  • func (s *Store) FindOneAssetByUUID(uuid string) (models.Asset, error)
  • func (s *Store) FindOneEnvByUUID(UUID string) (models.Env, error)
  • func (s *Store) FindOnePipelineByUUID(UUID string, withAssetValues bool) (models.Pipeline, error)
  • func (s *Store) FindOneXProcessorByName(name string) (models.XProcessor, error)
  • func (s *Store) FindOneXProcessorByUUID(UUID string, withAssetValues bool) (models.XProcessor, error)
  • func (s *Store) FindPipelines(withAssetValues bool) []models.Pipeline
  • func (s *Store) FindPipelinesWithAutoStart(withAssetValues bool) []models.Pipeline
  • func (s *Store) FindXProcessors(behavior string) []models.XProcessor
  • func (s *Store) NewProcessorStorage(processorType string) (*processorStorage, error)
  • func (s *Store) PipelineTmpPath(tPipeline *models.Pipeline) string
  • func (s *Store) PreparePipelineExecutionStage(tPipeline *models.Pipeline) (string, error)
  • func (s *Store) SaveAsset(a *models.Asset)
  • func (s *Store) SavePipeline(p *models.Pipeline)
  • func (s *Store) SaveXProcessor(xp *models.XProcessor)
• type StoreAsset
• type StoreAssetRef
• type StoreEnv
• type StorePipeline
• type StoreXProcessor

Types

type Store

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

func New

func New(location string, log commons.Logger) (*Store, error)

func (*Store) Close

func (s *Store) Close()

func (*Store) CopyTo

func (s *Store) CopyTo(w io.Writer) (int, error)

CopyTo writes the raw database's content to given io.Writer

func (*Store) CreateAsset

func (s *Store) CreateAsset(a *models.Asset)

func (*Store) CreateEnv

func (s *Store) CreateEnv(xp *models.Env)

func (*Store) CreatePipeline

func (s *Store) CreatePipeline(p *models.Pipeline)

func (*Store) CreateXProcessor

func (s *Store) CreateXProcessor(xp *models.XProcessor)

func (*Store) DeleteAsset

func (s *Store) DeleteAsset(a *models.Asset)

func (*Store) DeleteEnv

func (s *Store) DeleteEnv(p *models.Env)

func (*Store) DeletePipeline

func (s *Store) DeletePipeline(p *models.Pipeline)

func (*Store) DeleteXProcessor

func (s *Store) DeleteXProcessor(p *models.XProcessor)

func (*Store) FindAssetsByPipelineUUID

func (s *Store) FindAssetsByPipelineUUID(uuid string) ([]models.Asset, error)

func (*Store) FindEnvs

func (s *Store) FindEnvs() []models.Env

func (*Store) FindOneAssetByUUID

func (s *Store) FindOneAssetByUUID(uuid string) (models.Asset, error)

func (*Store) FindOneEnvByUUID

func (s *Store) FindOneEnvByUUID(UUID string) (models.Env, error)

func (*Store) FindOnePipelineByUUID

func (s *Store) FindOnePipelineByUUID(UUID string, withAssetValues bool) (models.Pipeline, error)

func (*Store) FindOneXProcessorByName

func (s *Store) FindOneXProcessorByName(name string) (models.XProcessor, error)

func (*Store) FindOneXProcessorByUUID

func (s *Store) FindOneXProcessorByUUID(UUID string, withAssetValues bool) (models.XProcessor, error)

func (*Store) FindPipelines

func (s *Store) FindPipelines(withAssetValues bool) []models.Pipeline

func (*Store) FindPipelinesWithAutoStart

func (s *Store) FindPipelinesWithAutoStart(withAssetValues bool) []models.Pipeline

func (*Store) FindXProcessors

func (s *Store) FindXProcessors(behavior string) []models.XProcessor

func (*Store) NewProcessorStorage

func (s *Store) NewProcessorStorage(processorType string) (*processorStorage, error)

func (*Store) PipelineTmpPath

func (s *Store) PipelineTmpPath(tPipeline *models.Pipeline) string

func (*Store) PreparePipelineExecutionStage

func (s *Store) PreparePipelineExecutionStage(tPipeline *models.Pipeline) (string, error)

func (*Store) SaveAsset

func (s *Store) SaveAsset(a *models.Asset)

func (*Store) SavePipeline

func (s *Store) SavePipeline(p *models.Pipeline)

func (*Store) SaveXProcessor

func (s *Store) SaveXProcessor(xp *models.XProcessor)

type StoreAsset

type StoreAsset struct {
	Uuid      string    `json:"uuid" boltholdKey:"Uuid"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`

	PipelineUUID string `boltholdIndex:"AssetPipelineUUID"`

	Label       string
	Type        string `boltholdIndex:"AssetType"`
	ContentType string
	Value       []byte
	Size        int
}

type StoreAssetRef

type StoreAssetRef struct {
	Uuid  string `json:"uuid" boltholdIndex:"PipelineAssetUUID"`
	Label string
	Type  string
}

type StoreEnv

type StoreEnv struct {
	Uuid string `json:"uuid" boltholdKey:"Uuid"`

	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`

	Name   string `json:"name"`
	Value  string `json:"value"`
	Secret bool   `json:"secret"`
}

type StorePipeline

type StorePipeline struct {
	Uuid string `json:"uuid" boltholdKey:"Uuid"`

	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
	StartedAt time.Time `json:"started_at"`

	Label       string `json:"label"`
	Description string `json:"description"`
	AutoStart   bool   `json:"auto_start" boltholdIndex:"AutoStart" mapstructure:"auto_start"`

	// Assets
	Assets []StoreAssetRef `json:"assets"`
}

type StoreXProcessor

type StoreXProcessor struct {
	Uuid string `json:"uuid" boltholdKey:"Uuid"`

	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`

	Label                 string   `json:"label" boltholdIndex:"Label" mapstructure:"label"`
	Description           string   `json:"description"`
	Behavior              string   `json:"behavior" boltholdIndex:"Behavior" mapstructure:"behavior"`
	Stream                bool     `json:"stream"`
	Kind                  string   `json:"kind"`
	Args                  []string `json:"args"`
	Code                  string   `json:"code"`
	Command               string   `json:"command"`
	StdinAs               string   `json:"stdin_as"`
	StdoutAs              string   `json:"stdout_as"`
	OptionsCompositionTpl string   `json:"options_composition_tpl"`
	HasDoc                bool     `json:"has_doc"`
}