Documentation ¶
Index ¶
- type Service
- func (s *Service) CreateCollection(c *domain.Collection) error
- func (s *Service) CreateJob(job *domain.JobDefinition) error
- func (s *Service) CreateVariable(Variable *domain.Variable) error
- func (s *Service) DeleteCollection(id string) error
- func (s *Service) DeleteJob(id string) error
- func (s *Service) DeleteJobHistory(id string, before time.Time) error
- func (s *Service) DeleteVariable(id string) error
- func (s *Service) Health() error
- func (s *Service) ListCollections() ([]*domain.CollectionItem, error)
- func (s *Service) ListJobHistory(id string) ([]*domain.JobHistory, error)
- func (s *Service) ListJobs(collectionId string, fields []string) ([]*domain.JobItem, error)
- func (s *Service) ListVariables(collectionID string) ([]*domain.VariableItem, error)
- func (s *Service) OnRunJob(j *domain.JobDefinition)
- func (s *Service) OnUpdateEvent(m *domain.UpdateEvent) error
- func (s *Service) RetrieveCollection(id string) (*domain.Collection, error)
- func (s *Service) RetrieveJob(id string) (*domain.JobDefinition, error)
- func (s *Service) RetrieveJobStatus(id string) (*domain.JobStatus, error)
- func (s *Service) RetrieveVariable(id string) (*domain.Variable, error)
- func (s *Service) RunJob(id string) error
- func (s *Service) Start()
- func (s *Service) Stop()
- func (s *Service) UpdateCollection(c *domain.Collection) error
- func (s *Service) UpdateJob(job *domain.JobDefinition) error
- func (s *Service) UpdateVariable(Variable *domain.Variable) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct { Repository domain.Repository Scheduler domain.Scheduler Runners map[string]domain.Runner // contains filtered or unexported fields }
func (*Service) CreateCollection ¶
func (s *Service) CreateCollection(c *domain.Collection) error
func (*Service) DeleteCollection ¶
func (*Service) DeleteJobHistory ¶
func (*Service) DeleteVariable ¶
func (*Service) ListCollections ¶
func (s *Service) ListCollections() ([]*domain.CollectionItem, error)
func (*Service) ListJobHistory ¶
func (s *Service) ListJobHistory(id string) ([]*domain.JobHistory, error)
func (*Service) ListVariables ¶
func (s *Service) ListVariables(collectionID string) ([]*domain.VariableItem, error)
func (*Service) OnRunJob ¶
func (s *Service) OnRunJob(j *domain.JobDefinition)
func (*Service) OnUpdateEvent ¶
func (s *Service) OnUpdateEvent(m *domain.UpdateEvent) error
func (*Service) RetrieveCollection ¶
func (s *Service) RetrieveCollection(id string) (*domain.Collection, error)
func (*Service) RetrieveJob ¶
func (s *Service) RetrieveJob(id string) (*domain.JobDefinition, error)
func (*Service) RetrieveJobStatus ¶
func (*Service) RetrieveVariable ¶
func (*Service) UpdateCollection ¶
func (s *Service) UpdateCollection(c *domain.Collection) error
Click to show internal directories.
Click to hide internal directories.