interfaces

type DBClient interface {
	CloseSession()

	// Return all the Interval(s)
	Intervals() ([]contract.Interval, error)

	// Return Interval(s) up to the number specified
	IntervalsWithLimit(limit int) ([]contract.Interval, error)

	// Return Interval by name
	IntervalByName(name string) (contract.Interval, error)

	// Return interval by contract id
	IntervalById(id string) (contract.Interval, error)

	// Add a new Interval
	AddInterval(interval contract.Interval) (string, error)

	// Update an Interval
	UpdateInterval(interval contract.Interval) error

	// Remove Interval by id
	DeleteIntervalById(id string) error

	// Get all IntervalAction(s)
	IntervalActions() ([]contract.IntervalAction, error)

	// Return IntervalAction(s) up to the number specified
	IntervalActionsWithLimit(limit int) ([]contract.IntervalAction, error)

	// Get all IntervalAction(s) by interval name
	IntervalActionsByIntervalName(name string) ([]contract.IntervalAction, error)

	// Get all IntervalAction(s) by target name
	IntervalActionsByTarget(name string) ([]contract.IntervalAction, error)

	// Get IntervalAction by id
	IntervalActionById(id string) (contract.IntervalAction, error)

	// Get IntervalAction by name
	IntervalActionByName(name string) (contract.IntervalAction, error)

	// Add IntervalAction
	AddIntervalAction(intervalAction contract.IntervalAction) (string, error)

	// Update IntervalAction
	UpdateIntervalAction(intervalAction contract.IntervalAction) error

	// Remove IntervalAction by id
	DeleteIntervalActionById(id string) error

	// Scrub all scheduler interval actions from the database data (only used in test)
	ScrubAllIntervalActions() (int, error)

	// Scrub all scheduler intervals from the database (only used in test)
	ScrubAllIntervals() (int, error)
}

type SchedulerQueueClient interface {

	// Return Interval by ID from the Scheduler Interval Context
	QueryIntervalByID(intervalId string) (contract.Interval, error)

	// Return Interval by Name from the Scheduler Interval Context
	QueryIntervalByName(intervalName string) (contract.Interval, error)

	// Add Interval into the Scheduler Queue
	AddIntervalToQueue(interval contract.Interval) error

	// Update Interval in the Scheduler Queue
	UpdateIntervalInQueue(interval contract.Interval) error

	// Remote the Interval from the Scheduler Queue
	RemoveIntervalInQueue(intervalId string) error

	// Return IntervalAction by ID from the Scheduler IntervalAction Context
	QueryIntervalActionByID(intervalActionId string) (contract.IntervalAction, error)

	// Return IntervalAction by Name from the Scheduler IntervalAction Context
	QueryIntervalActionByName(intervalActionName string) (contract.IntervalAction, error)

	// Add IntervalAction into Scheduler Queue
	AddIntervalActionToQueue(intervalAction contract.IntervalAction) error

	// Update IntervalAction in the Scheduler Queue
	UpdateIntervalActionQueue(intervalAction contract.IntervalAction) error

	// Remove IntervalAction from the Scheduler Queue
	RemoveIntervalActionQueue(intervalActionId string) error

	// Check if we can connect to Scheduler Queue
	Connect() (string, error)
}