config

Documentation

Index

• Constants
• Variables
• func LoadConfiguration(path string) (map[string]Task, error)
• type Destination
• type DestinationType
• type S3Credentials
• type S3DestinationDefinition
  • func (d S3DestinationDefinition) Client() *s3.S3
  • func (d S3DestinationDefinition) Key(timestamp time.Time) string
  • func (d S3DestinationDefinition) ParseTimestamp(key string) (time.Time, error)
• type Task

Constants

const S3_TIME_FORMAT = "20060102150405"

Variables

var ErrUnsupportedConfigFile = errors.New("unsupported config file")

Functions

func LoadConfiguration

func LoadConfiguration(path string) (map[string]Task, error)

Types

type Destination

type Destination struct {
	Type DestinationType         `json:"type" toml:"type"`
	S3   S3DestinationDefinition `json:"s3" toml:"s3"`
}

type DestinationType

type DestinationType string

const (
	S3Destination DestinationType = "s3"
)

type S3Credentials

type S3Credentials struct {
	AccessKeyId     string `json:"access_key_id" toml:"access_key_id"`
	SecretAccessKey string `json:"secret_access_key" toml:"secret_access_key"`
	SessionToken    string `json:"session_token,omitempty" toml:"session_token,omitempty"`
}

type S3DestinationDefinition

type S3DestinationDefinition struct {
	Bucket      string         `json:"bucket" toml:"bucket"`
	Prefix      string         `json:"prefix" toml:"prefix"`
	Suffix      string         `json:"suffix" toml:"suffix"`
	Region      string         `json:"region" toml:"region"`
	Credentials *S3Credentials `json:"credentials" toml:"credentials"`
	Profile     *string        `json:"profile" toml:"profile"`
}

func (S3DestinationDefinition) Client

func (d S3DestinationDefinition) Client() *s3.S3

func (S3DestinationDefinition) Key

func (d S3DestinationDefinition) Key(timestamp time.Time) string

func (S3DestinationDefinition) ParseTimestamp

func (d S3DestinationDefinition) ParseTimestamp(key string) (time.Time, error)

type Task

type Task struct {
	Schedule    utils.ScheduleExpression `json:"schedule" toml:"schedule"`
	Command     []string                 `json:"command" toml:"command"`
	Cwd         string                   `json:"cwd" toml:"cwd"`
	Env         []string                 `json:"env" toml:"env"`
	Timeout     string                   `json:"timeout" toml:"timeout"`
	Destination Destination              `json:"destination" toml:"destination"`
}