jobs

type Config struct {
	Name string      `mapstructure:"name"`
	Exec interface{} `mapstructure:"exec"`

	// service discovery
	Port          int           `mapstructure:"port"`
	InitialStatus string        `mapstructure:"initial_status"`
	Interfaces    interface{}   `mapstructure:"interfaces"`
	Tags          []string      `mapstructure:"tags"`
	ConsulExtras  *ConsulExtras `mapstructure:"consul"`

	// health checking
	Health *HealthConfig `mapstructure:"health"`

	// timeouts and restarts
	ExecTimeout string      `mapstructure:"timeout"`
	Restarts    interface{} `mapstructure:"restarts"`
	StopTimeout string      `mapstructure:"stopTimeout"`

	// related jobs and frequency
	When *WhenConfig `mapstructure:"when"`

	// logging
	Logging *LoggingConfig `mapstructure:"logging"`
	// contains filtered or unexported fields
}

type ConsulExtras struct {
	EnableTagOverride              bool   `mapstructure:"enableTagOverride"`
	DeregisterCriticalServiceAfter string `mapstructure:"deregisterCriticalServiceAfter"`
}

type HealthConfig struct {
	CheckExec    interface{}    `mapstructure:"exec"`
	CheckTimeout string         `mapstructure:"timeout"`
	Heartbeat    int            `mapstructure:"interval"` // time in seconds
	TTL          int            `mapstructure:"ttl"`      // time in seconds
	Logging      *LoggingConfig `mapstructure:"logging"`
}

type Job struct {
	Name string

	// service health and discovery
	Status JobStatus

	Service *discovery.ServiceDefinition

	// completed
	IsComplete bool

	events.Subscriber
	events.Publisher
	// contains filtered or unexported fields
}

type JobStatus int

type LoggingConfig struct {
	Raw bool `mapstructure:"raw"`
}

type WhenConfig struct {
	Frequency string `mapstructure:"interval"`
	Source    string `mapstructure:"source"`
	Once      string `mapstructure:"once"`
	Each      string `mapstructure:"each"`
	Timeout   string `mapstructure:"timeout"`
}