resources

Documentation

Index

• func API(api []byte) func(w http.ResponseWriter, r *http.Request)
• func CreateCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func DeleteCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func GetCycleForID(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func GetCycleThrottle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func GetCycles(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func LogLevel(w http.ResponseWriter, r *http.Request)
• func ResetCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func ResumeCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func SetCycleThrottle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func ShutdownScheduler(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func StartScheduler(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• func StopCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)
• type HealthService
  • func NewHealthService(appSystemCode string, appName string, description string, db native.DB, ...) *HealthService
  • func (healthService *HealthService) GTG() gtg.Status
  • func (healthService *HealthService) Health() func(w http.ResponseWriter, r *http.Request)

Functions

func API

func API(api []byte) func(w http.ResponseWriter, r *http.Request)

API returns the swagger.yml for this service.

func CreateCycle

func CreateCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

CreateCycle POST request to create a new cycle

func DeleteCycle

func DeleteCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

DeleteCycle deletes the cycle by the given id

func GetCycleForID

func GetCycleForID(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

GetCycleForID returns the individual cycle

func GetCycleThrottle

func GetCycleThrottle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

Get a cycle throttle

func GetCycles

func GetCycles(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

GetCycles returns all cycles as an array

func LogLevel

func LogLevel(w http.ResponseWriter, r *http.Request)

LogLevel handles request to change the logging level between debug and info

func ResetCycle

func ResetCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

ResetCycle stops and completely resets the given cycle

func ResumeCycle

func ResumeCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

ResumeCycle resumes the stopped cycle.

func SetCycleThrottle

func SetCycleThrottle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

Set a cycle throttle

func ShutdownScheduler

func ShutdownScheduler(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

ShutdownScheduler stops all cycles

func StartScheduler

func StartScheduler(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

StartScheduler resumes all cycles

func StopCycle

func StopCycle(sched scheduler.Scheduler) func(w http.ResponseWriter, r *http.Request)

StopCycle stops the given cycle ID

Types

type HealthService

type HealthService struct {
	// contains filtered or unexported fields
}

func NewHealthService

func NewHealthService(appSystemCode string, appName string, description string, db native.DB, s3Service s3.ReadWriter, notifier cms.Notifier, sched scheduler.Scheduler, configError error, upServices ...cluster.Service) *HealthService

func (*HealthService) GTG

func (healthService *HealthService) GTG() gtg.Status

GTG returns a handler for a standard GTG endpoint.

func (*HealthService) Health

func (healthService *HealthService) Health() func(w http.ResponseWriter, r *http.Request)

Health returns a handler for the standard FT healthchecks