core

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

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) CreateJob

func (s *Service) CreateJob(job *domain.JobDefinition) error

func (*Service) CreateVariable

func (s *Service) CreateVariable(Variable *domain.Variable) error

func (*Service) DeleteCollection

func (s *Service) DeleteCollection(id string) error

func (*Service) DeleteJob

func (s *Service) DeleteJob(id string) error

func (*Service) DeleteJobHistory

func (s *Service) DeleteJobHistory(id string, before time.Time) error

func (*Service) DeleteVariable

func (s *Service) DeleteVariable(id string) error

func (*Service) Health

func (s *Service) Health() error

func (*Service) ListCollections

func (s *Service) ListCollections() ([]*domain.CollectionItem, error)

func (*Service) ListJobHistory

func (s *Service) ListJobHistory(id string) ([]*domain.JobHistory, error)

func (*Service) ListJobs

func (s *Service) ListJobs(collectionId string, fields []string) ([]*domain.JobItem, 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 (s *Service) RetrieveJobStatus(id string) (*domain.JobStatus, error)

func (*Service) RetrieveVariable

func (s *Service) RetrieveVariable(id string) (*domain.Variable, error)

func (*Service) RunJob

func (s *Service) RunJob(id string) error

func (*Service) Start

func (s *Service) Start()

func (*Service) Stop

func (s *Service) Stop()

func (*Service) UpdateCollection

func (s *Service) UpdateCollection(c *domain.Collection) error

func (*Service) UpdateJob

func (s *Service) UpdateJob(job *domain.JobDefinition) error

func (*Service) UpdateVariable

func (s *Service) UpdateVariable(Variable *domain.Variable) error