Documentation
¶
Index ¶
- type Store
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) CreateAsset ¶
func (*Store) CreatePipeline ¶
func (*Store) CreateXProcessor ¶
func (s *Store) CreateXProcessor(xp *models.XProcessor)
func (*Store) DeleteAsset ¶
func (*Store) DeletePipeline ¶
func (*Store) DeleteXProcessor ¶
func (s *Store) DeleteXProcessor(p *models.XProcessor)
func (*Store) FindAssetsByPipelineUUID ¶
func (*Store) FindOneAssetByUUID ¶
func (*Store) FindOnePipelineByUUID ¶
func (*Store) FindOneXProcessorByName ¶
func (s *Store) FindOneXProcessorByName(name string) (models.XProcessor, error)
func (*Store) FindOneXProcessorByUUID ¶
func (*Store) FindPipelinesWithAutoStart ¶
func (*Store) FindXProcessors ¶
func (s *Store) FindXProcessors(behavior string) []models.XProcessor
func (*Store) NewProcessorStorage ¶
func (*Store) PreparePipelineExecutionStage ¶
func (*Store) SavePipeline ¶
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 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"`
}
Click to show internal directories.
Click to hide internal directories.