Documentation ¶
Index ¶
- type Catalog
- func (c *Catalog) Add(obj interface{}) error
- func (c *Catalog) Delete(name string, t reflect.Type) error
- func (c *Catalog) Dump() map[string]interface{}
- func (c *Catalog) Get(name string, t reflect.Type) (core.Base, bool)
- func (c *Catalog) List(t reflect.Type) interface{}
- func (c *Catalog) Lock()
- func (c *Catalog) SafeDump() map[string]interface{}
- func (c *Catalog) Unlock()
- func (c *Catalog) Update(obj interface{}) error
- type RailgunCatalog
- func (c *RailgunCatalog) DeleteDataStore(name string) error
- func (c *RailgunCatalog) DeleteItem(name string, t reflect.Type) error
- func (c *RailgunCatalog) DeleteJob(name string) error
- func (c *RailgunCatalog) DeleteLayer(name string) error
- func (c *RailgunCatalog) DeleteProcess(name string) error
- func (c *RailgunCatalog) DeleteService(name string) error
- func (c *RailgunCatalog) DeleteWorkflow(name string) error
- func (c *RailgunCatalog) DeleteWorkspace(name string) error
- func (c *RailgunCatalog) GetDataStore(name string) (*core.DataStore, bool)
- func (c *RailgunCatalog) GetItem(name string, t reflect.Type) (core.Base, bool)
- func (c *RailgunCatalog) GetJob(name string) (*core.Job, bool)
- func (c *RailgunCatalog) GetJobs(names []string) ([]*core.Job, error)
- func (c *RailgunCatalog) GetLayer(name string) (*core.Layer, bool)
- func (c *RailgunCatalog) GetProcess(name string) (*core.Process, bool)
- func (c *RailgunCatalog) GetService(name string) (*core.Service, bool)
- func (c *RailgunCatalog) GetWorkflow(name string) (*core.Workflow, bool)
- func (c *RailgunCatalog) GetWorkspace(name string) (*core.Workspace, bool)
- func (c *RailgunCatalog) ListDataStores() []*core.DataStore
- func (c *RailgunCatalog) ListJobs() []*core.Job
- func (c *RailgunCatalog) ListLayers() []*core.Layer
- func (c *RailgunCatalog) ListProcesses() []*core.Process
- func (c *RailgunCatalog) ListServices() []*core.Service
- func (c *RailgunCatalog) ListWorkflows() []*core.Workflow
- func (c *RailgunCatalog) ListWorkspaces() []*core.Workspace
- func (c *RailgunCatalog) LoadFromUri(uri string, logWriter grw.ByteWriteCloser, errorWriter grw.ByteWriteCloser, ...) error
- func (c *RailgunCatalog) LoadFromViper(v *viper.Viper) error
- func (c *RailgunCatalog) ParseDataStore(obj interface{}) (*core.DataStore, error)
- func (c *RailgunCatalog) ParseItem(obj interface{}, t reflect.Type) (core.Base, error)
- func (c *RailgunCatalog) ParseJob(obj interface{}) (*core.Job, error)
- func (c *RailgunCatalog) ParseLayer(obj interface{}) (*core.Layer, error)
- func (c *RailgunCatalog) ParseProcess(obj interface{}) (*core.Process, error)
- func (c *RailgunCatalog) ParseService(obj interface{}) (*core.Service, error)
- func (c *RailgunCatalog) ParseWorkflow(obj interface{}) (*core.Workflow, error)
- func (c *RailgunCatalog) ParseWorkspace(obj interface{}) (*core.Workspace, error)
- func (c *RailgunCatalog) SaveToUri(uri string, s3_client *s3.S3) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Catalog ¶
type Catalog struct {
// contains filtered or unexported fields
}
func NewCatalog ¶
func NewCatalog() *Catalog
type RailgunCatalog ¶
type RailgunCatalog struct {
*Catalog
}
func NewRailgunCatalog ¶
func NewRailgunCatalog() *RailgunCatalog
func (*RailgunCatalog) DeleteDataStore ¶
func (c *RailgunCatalog) DeleteDataStore(name string) error
func (*RailgunCatalog) DeleteItem ¶
func (c *RailgunCatalog) DeleteItem(name string, t reflect.Type) error
func (*RailgunCatalog) DeleteJob ¶
func (c *RailgunCatalog) DeleteJob(name string) error
func (*RailgunCatalog) DeleteLayer ¶
func (c *RailgunCatalog) DeleteLayer(name string) error
func (*RailgunCatalog) DeleteProcess ¶
func (c *RailgunCatalog) DeleteProcess(name string) error
func (*RailgunCatalog) DeleteService ¶
func (c *RailgunCatalog) DeleteService(name string) error
func (*RailgunCatalog) DeleteWorkflow ¶
func (c *RailgunCatalog) DeleteWorkflow(name string) error
func (*RailgunCatalog) DeleteWorkspace ¶
func (c *RailgunCatalog) DeleteWorkspace(name string) error
func (*RailgunCatalog) GetDataStore ¶
func (c *RailgunCatalog) GetDataStore(name string) (*core.DataStore, bool)
func (*RailgunCatalog) GetJobs ¶
func (c *RailgunCatalog) GetJobs(names []string) ([]*core.Job, error)
func (*RailgunCatalog) GetLayer ¶
func (c *RailgunCatalog) GetLayer(name string) (*core.Layer, bool)
func (*RailgunCatalog) GetProcess ¶
func (c *RailgunCatalog) GetProcess(name string) (*core.Process, bool)
func (*RailgunCatalog) GetService ¶
func (c *RailgunCatalog) GetService(name string) (*core.Service, bool)
func (*RailgunCatalog) GetWorkflow ¶
func (c *RailgunCatalog) GetWorkflow(name string) (*core.Workflow, bool)
func (*RailgunCatalog) GetWorkspace ¶
func (c *RailgunCatalog) GetWorkspace(name string) (*core.Workspace, bool)
func (*RailgunCatalog) ListDataStores ¶
func (c *RailgunCatalog) ListDataStores() []*core.DataStore
func (*RailgunCatalog) ListJobs ¶
func (c *RailgunCatalog) ListJobs() []*core.Job
func (*RailgunCatalog) ListLayers ¶
func (c *RailgunCatalog) ListLayers() []*core.Layer
func (*RailgunCatalog) ListProcesses ¶
func (c *RailgunCatalog) ListProcesses() []*core.Process
func (*RailgunCatalog) ListServices ¶
func (c *RailgunCatalog) ListServices() []*core.Service
func (*RailgunCatalog) ListWorkflows ¶
func (c *RailgunCatalog) ListWorkflows() []*core.Workflow
func (*RailgunCatalog) ListWorkspaces ¶
func (c *RailgunCatalog) ListWorkspaces() []*core.Workspace
func (*RailgunCatalog) LoadFromUri ¶
func (c *RailgunCatalog) LoadFromUri(uri string, logWriter grw.ByteWriteCloser, errorWriter grw.ByteWriteCloser, s3_client *s3.S3) error
func (*RailgunCatalog) LoadFromViper ¶
func (c *RailgunCatalog) LoadFromViper(v *viper.Viper) error
func (*RailgunCatalog) ParseDataStore ¶
func (c *RailgunCatalog) ParseDataStore(obj interface{}) (*core.DataStore, error)
func (*RailgunCatalog) ParseJob ¶
func (c *RailgunCatalog) ParseJob(obj interface{}) (*core.Job, error)
func (*RailgunCatalog) ParseLayer ¶
func (c *RailgunCatalog) ParseLayer(obj interface{}) (*core.Layer, error)
func (*RailgunCatalog) ParseProcess ¶
func (c *RailgunCatalog) ParseProcess(obj interface{}) (*core.Process, error)
func (*RailgunCatalog) ParseService ¶
func (c *RailgunCatalog) ParseService(obj interface{}) (*core.Service, error)
func (*RailgunCatalog) ParseWorkflow ¶
func (c *RailgunCatalog) ParseWorkflow(obj interface{}) (*core.Workflow, error)
func (*RailgunCatalog) ParseWorkspace ¶
func (c *RailgunCatalog) ParseWorkspace(obj interface{}) (*core.Workspace, error)
Click to show internal directories.
Click to hide internal directories.