eventline

type APIKey struct {
	Id           Id         `json:"id"`
	AccountId    Id         `json:"account_id"`
	Name         string     `json:"name"`
	CreationTime time.Time  `json:"creation_time"`
	LastUseTime  *time.Time `json:"last_use_time,omitempty"`
	KeyHash      []byte     `json:"-"`
}

type APIKeys []*APIKey

type Account struct {
	Id            Id               `json:"id"`
	CreationTime  time.Time        `json:"creation_time"`
	Username      string           `json:"username"`
	Salt          []byte           `json:"-"`
	PasswordHash  []byte           `json:"-"`
	Role          AccountRole      `json:"role"`
	LastLoginTime *time.Time       `json:"last_login_time,omitempty"`
	LastProjectId *Id              `json:"last_project_id,omitempty"`
	Settings      *AccountSettings `json:"settings"`
}

type AccountPasswordUpdate struct {
	Password             string `json:"password"`
	PasswordConfirmation string `json:"password_confirmation"`
}

type AccountProjectScope struct {
	AccountId Id
	ProjectId Id
}

type AccountRole string

type AccountScope struct {
	AccountId Id
}

type AccountSelfUpdate struct {
	Settings *AccountSettings `json:"settings"`
}

type AccountSettings struct {
	DateFormat DateFormat `json:"date_format,omitempty"`
	PageSize   int        `json:"page_size,omitempty"`
}

type AccountUpdate struct {
	Username string      `json:"username"`
	Role     AccountRole `json:"role"`
}

type Accounts []*Account

type CommandData struct {
	Parameters []*Parameter `json:"parameters,omitempty"`
	Pipelines  []string     `json:"pipelines"` //names
}

type Connector interface {
	Name() string
	Definition() *ConnectorDef
	DefaultCfg() ConnectorCfg

	Init(ConnectorCfg, ConnectorInitData) error
	Terminate()
}

type ConnectorCfg interface {
	ejson.Validatable
}

type ConnectorDef struct {
	Name string

	Identities map[string]*IdentityDef
	Events     map[string]*EventDef

	Worker WorkerBehaviour
}

type ConnectorInitData struct {
	Pg               *pg.Client
	Log              *log.Logger
	WebHTTPServerURI *url.URL
}

type Cursor struct {
	Before string `json:"before,omitempty"`
	After  string `json:"after,omitempty"`
	Size   int    `json:"size,omitempty"`
	Sort   string `json:"sort,omitempty"`
	Order  Order  `json:"order,omitempty"`
}

type DateFormat string

type Event struct {
	Id              Id          `json:"id"`
	ProjectId       Id          `json:"project_id"`
	JobId           Id          `json:"job_id"`
	CreationTime    time.Time   `json:"creation_time"`
	EventTime       time.Time   `json:"event_time"`
	Connector       string      `json:"connector"`
	Name            string      `json:"name"`
	Data            EventData   `json:"data"`
	DataValue       interface{} `json:"-"`
	Processed       bool        `json:"processed,omitempty"`
	OriginalEventId *Id         `json:"original_event_id,omitempty"`
}

type EventData interface {
}

type EventDef struct {
	Name string

	Data                   EventData
	SubscriptionParameters SubscriptionParameters
}

type EventRef struct {
	Connector string
	Event     string
}

type Events []*Event

type ExecutionContext struct {
	Event      *Event                 `json:"event,omitempty"`
	Parameters map[string]interface{} `json:"parameters,omitempty"`
	Identities map[string]*Identity   `json:"identities,omitempty"`
}

type ExternalSubscriptionError struct {
	Err error
}

type FavouriteJob struct {
	AccountId Id
	ProjectId Id
	JobId     Id
}

type FileSet struct {
	Files map[string]*FileSetFile
}

type FileSetFile struct {
	Content []byte
	Mode    os.FileMode
}

type Filter struct {
	Path           ejson.Pointer  `json:"path"`
	IsEqualTo      interface{}    `json:"is_equal_to,omitempty"`
	IsNotEqualTo   interface{}    `json:"is_not_equal_to,omitempty"`
	Matches        string         `json:"matches,omitempty"`
	MatchesRE      *regexp.Regexp `json:"-"`
	DoesNotMatch   string         `json:"does_not_match,omitempty"`
	DoesNotMatchRE *regexp.Regexp `json:"-"`
}

type Filters []*Filter

type GlobalScope struct {
}

type Id = ksuid.KSUID

type Identities []*Identity

type Identity struct {
	Id           Id              `json:"id"`
	ProjectId    *Id             `json:"project_id"`
	Name         string          `json:"name"`
	Status       IdentityStatus  `json:"status"`
	ErrorMessage string          `json:"error_message,omitempty"`
	CreationTime time.Time       `json:"creation_time"`
	UpdateTime   time.Time       `json:"update_time"`
	LastUseTime  *time.Time      `json:"last_use_time,omitempty"`
	RefreshTime  *time.Time      `json:"refresh_time,omitempty"`
	Connector    string          `json:"connector"`
	Type         string          `json:"type"`
	Data         IdentityData    `json:"-"`
	RawData      json.RawMessage `json:"data"`
}

type IdentityData interface {
	ejson.Validatable

	Def() *IdentityDataDef
	Environment() map[string]string
}

type IdentityDataDef struct {
	Entries []*IdentityDataEntry
}

type IdentityDataEntry struct {
	Key                   string
	Label                 string
	Value                 interface{}
	Type                  IdentityDataType
	EnumValues            []string
	PreselectedEnumValues []string
	MultiselectEnumSize   int // size of the multiselect html element
	Optional              bool
	Verbatim              bool
	Secret                bool
	Internal              bool // set by eventline, not by the user
}

type IdentityDataType string

type IdentityDef struct {
	Type string

	DeferredReadiness bool
	Refreshable       bool

	Data    IdentityData
	DataDef *IdentityDataDef // used when there is no actual identity
}

type IdentityStatus string

type Ids = ksuid.KSUIDs

type Job struct {
	Id           Id        `json:"id"`
	ProjectId    Id        `json:"project_id"`
	CreationTime time.Time `json:"creation_time"`
	UpdateTime   time.Time `json:"update_time"`
	Disabled     bool      `json:"disabled,omitempty"`
	Spec         *JobSpec  `json:"spec"`
}

type JobExecution struct {
	Id             Id                     `json:"id"`
	ProjectId      Id                     `json:"project_id"`
	JobId          Id                     `json:"job_id"`
	JobSpec        *JobSpec               `json:"job_spec"`
	EventId        *Id                    `json:"event_id,omitempty"`
	Parameters     map[string]interface{} `json:"parameters,omitempty"`
	CreationTime   time.Time              `json:"creation_time"`
	UpdateTime     time.Time              `json:"update_time"`
	ScheduledTime  time.Time              `json:"scheduled_time,omitempty"`
	Status         JobExecutionStatus     `json:"status"`
	StartTime      *time.Time             `json:"start_time,omitempty"`
	EndTime        *time.Time             `json:"end_time,omitempty"`
	RefreshTime    *time.Time             `json:"refresh_time,omitempty"`
	ExpirationTime *time.Time             `json:"expiration_time,omitempty"`
	FailureMessage string                 `json:"failure_message,omitempty"`
}

type JobExecutionAbortedError struct {
	Id Id
}

type JobExecutionFinishedError struct {
	Id Id
}

type JobExecutionInput struct {
	Parameters    map[string]interface{} `json:"-"`
	RawParameters json.RawMessage        `json:"parameters"`
}

type JobExecutionNotFinishedError struct {
	Id Id
}

type JobExecutionPageOptions struct {
	JobId *Id
}

type JobExecutionStatus string

type JobExecutions []*JobExecution

type JobPageOptions struct {
	ExcludeFavouriteJobAccountId *Id
}

type JobRenamingData struct {
	Name        string `json:"name"`
	Description string `json:"description,omitempty"`
}

type JobRunner struct {
	Name          string           `json:"name"`
	Parameters    RunnerParameters `json:"-"`
	RawParameters json.RawMessage  `json:"parameters"`
	Identity      string           `json:"identity,omitempty"`
}

type JobSpec struct {
	Name        string `json:"name"`
	Description string `json:"description"`

	Trigger    *Trigger   `json:"trigger,omitempty"`
	Parameters Parameters `json:"parameters,omitempty"`

	Runner     *JobRunner `json:"runner"`
	Concurrent bool       `json:"concurrent,omitempty"`

	Retention int `json:"retention,omitempty"` // days

	Identities  []string          `json:"identities,omitempty"`
	Environment map[string]string `json:"environment,omitempty"`
	Steps       Steps             `json:"steps"`
}

type JobSpecs []*JobSpec

type JobStats struct {
	JobId        Id             `json:"job_id"`
	NbExecutions int            `json:"nb_executions"`
	DurationP50  *time.Duration `json:"duration_p50,omitempty"`
	SuccessRatio float64        `json:"success_ratio"` // last 7 days
}

type JobStatsList []*JobStats

type Jobs []*Job

type MetricGranularity string

type MetricParameters struct {
	Start       time.Time
	End         time.Time
	Granularity MetricGranularity
}

type MetricPoint []interface{}

type MetricPoints []MetricPoint

type NewAPIKey struct {
	Name string `json:"name"`
}

type NewAccount struct {
	Username             string      `json:"username"`
	Password             string      `json:"password"`
	PasswordConfirmation string      `json:"password_confirmation"`
	Role                 AccountRole `json:"role"`
}

type NewEvent struct {
	EventTime time.Time       `json:"event_time"`
	Connector string          `json:"connector"`
	Name      string          `json:"name"`
	Data      EventData       `json:"-"`
	RawData   json.RawMessage `json:"data"`
}

type NewIdentity struct {
	Name      string          `json:"name"`
	Connector string          `json:"connector"`
	Type      string          `json:"type"`
	Data      IdentityData    `json:"-"`
	RawData   json.RawMessage `json:"data"`
}

type NewProject struct {
	Name string `json:"name"`
}

type NewSession struct {
	Data            *SessionData     `json:"data"`
	AccountRole     AccountRole      `json:"account_role"`
	AccountSettings *AccountSettings `json:"account_settings"`
}

type Notification struct {
	Id               Id
	ProjectId        Id
	Recipients       []string
	Message          []byte
	NextDeliveryTime time.Time
	DeliveryDelay    int // seconds
}

type NullProjectScope struct {
}

type OAuth2IdentityData interface {
	IdentityData

	RedirectionURI(*http.Client, string, string) (string, error)
	FetchTokenData(*http.Client, string, string) error
}

type OptionalConnector interface {
	Connector

	Enabled() bool
}

type Order string

type Page struct {
	Elements []PageElement `json:"elements"`
	Previous *Cursor       `json:"previous,omitempty"`
	Next     *Cursor       `json:"next,omitempty"`
}

type PageElement interface {
	SortKey(string) string
}

type Parameter struct {
	Name        string          `json:"name"`
	Type        ParameterType   `json:"type"`
	Values      []string        `json:"values,omitempty"`
	Default     interface{}     `json:"-"`
	RawDefault  json.RawMessage `json:"default,omitempty"`
	Description string          `json:"description,omitempty"`
	Environment string          `json:"environment,omitempty"`
}

type ParameterType string

type Parameters []*Parameter

type Project struct {
	Id           Id        `json:"id"`
	Name         string    `json:"name"`
	CreationTime time.Time `json:"creation_time"`
	UpdateTime   time.Time `json:"update_time"`
}

type ProjectNotificationSettings struct {
	Id                     Id       `json:"id"` // ignored in input
	OnSuccessfulJob        bool     `json:"on_successful_job,omitempty"`
	OnFirstSuccessfulJob   bool     `json:"on_first_successful_job,omitempty"`
	OnFailedJob            bool     `json:"on_failed_job,omitempty"`
	OnAbortedJob           bool     `json:"on_aborted_job,omitempty"`
	OnIdentityRefreshError bool     `json:"on_identity_refresh_error,omitempty"`
	EmailAddresses         []string `json:"email_addresses"`
}

type ProjectScope struct {
	ProjectId Id
}

type ProjectSettings struct {
	Id         Id     `json:"id"` // Ignored in input
	CodeHeader string `json:"code_header"`
}

type Projects []*Project

type RawIdentities []*RawIdentity

type RawIdentity Identity

type RawNewIdentity NewIdentity

type RefreshableOAuth2IdentityData interface {
	OAuth2IdentityData

	Refresh(*http.Client) error
	RefreshTime() time.Time
}

type Runner struct {
	Log       *log.Logger
	Pg        *pg.Client
	Cfg       RunnerCfg
	Behaviour RunnerBehaviour

	JobExecution     *JobExecution
	StepExecutions   StepExecutions
	ExecutionContext *ExecutionContext
	Project          *Project
	ProjectSettings  *ProjectSettings

	RunnerIdentity *Identity

	Environment map[string]string
	FileSet     *FileSet
	Scope       Scope

	StopChan <-chan struct{}
	Wg       *sync.WaitGroup
	// contains filtered or unexported fields
}

type RunnerBehaviour interface {
	DirPath() string

	Init(ctx context.Context) error
	Terminate()

	ExecuteStep(context.Context, *StepExecution, *Step, io.WriteCloser, io.WriteCloser) error
}

type RunnerCfg interface {
	ejson.Validatable
}

type RunnerData struct {
	JobExecution     *JobExecution
	StepExecutions   StepExecutions
	ExecutionContext *ExecutionContext
	Project          *Project
	ProjectSettings  *ProjectSettings
}

type RunnerDef struct {
	Name                  string
	Cfg                   RunnerCfg
	InstantiateParameters func() RunnerParameters
	InstantiateBehaviour  func(*Runner) RunnerBehaviour
}

type RunnerInitData struct {
	Log *log.Logger
	Pg  *pg.Client

	Def  *RunnerDef
	Cfg  RunnerCfg
	Data *RunnerData

	TerminationChan chan<- Id

	RefreshInterval time.Duration

	StopChan <-chan struct{}
	Wg       *sync.WaitGroup
}

type RunnerParameters interface {
	ejson.Validatable
}

type Scope interface {
	SQLCondition() string
	SQLCondition2(string) string
}

type Session struct {
	Id              Id               `json:"id"`
	AccountId       Id               `json:"account_id"`
	CreationTime    time.Time        `json:"creation_time"`
	UpdateTime      time.Time        `json:"update_time"`
	Data            *SessionData     `json:"data"`
	AccountRole     AccountRole      `json:"account_role"`
	AccountSettings *AccountSettings `json:"account_settings"`
}

type SessionData struct {
	ProjectId *Id `json:"project_id,omitempty"`
}

type Shebang struct {
	Interpreter string
	Argument    string
}

type Sorts struct {
	Sorts   map[string]string
	Default string
}

type Step struct {
	Label string `json:"label,omitempty"`

	Code    string       `json:"code,omitempty"`
	Command *StepCommand `json:"command,omitempty"`
	Script  *StepScript  `json:"script,omitempty"`

	OnFailure StepFailureAction `json:"on_failure,omitempty"`
}

type StepCommand struct {
	Name      string   `json:"name"`
	Arguments []string `json:"arguments,omitempty"`
}

type StepExecution struct {
	Id             Id                  `json:"id"`
	ProjectId      Id                  `json:"project_id"`
	JobExecutionId Id                  `json:"job_execution_id"`
	Position       int                 `json:"position"`
	Status         StepExecutionStatus `json:"status"`
	StartTime      *time.Time          `json:"start_time,omitempty"`
	EndTime        *time.Time          `json:"end_time,omitempty"`
	FailureMessage string              `json:"failure_message,omitempty"`
	Output         string              `json:"output,omitempty"`
}

type StepExecutionStatus string

type StepExecutions []*StepExecution

type StepFailureAction string

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

type StepScript struct {
	Path      string   `json:"path"`
	Arguments []string `json:"arguments,omitempty"`

	Content string `json:"content,omitempty"` // content of the script file
}

type Steps []*Step

type SubscribableConnector interface {
	Connector

	Subscribe(pg.Conn, *SubscriptionContext) error
	Unsubscribe(pg.Conn, *SubscriptionContext) error
}

type Subscription struct {
	Id             Id
	ProjectId      *Id
	JobId          *Id
	IdentityId     *Id
	Connector      string
	Event          string
	Parameters     SubscriptionParameters
	CreationTime   time.Time
	Status         SubscriptionStatus
	UpdateDelay    int // seconds
	LastUpdateTime *time.Time
	NextUpdateTime *time.Time
}

type SubscriptionContext struct {
	Subscription *Subscription
	Identity     *Identity
	Job          *Job

	Scope Scope
}

type SubscriptionParameters interface {
	ejson.Validatable
}

type SubscriptionStatus string

type Subscriptions []*Subscription

type Trigger struct {
	Event         EventRef               `json:"event"`
	Parameters    SubscriptionParameters `json:"-"`
	RawParameters json.RawMessage        `json:"parameters,omitempty"`
	Identity      string                 `json:"identity,omitempty"`
	Filters       Filters                `json:"filters,omitempty"`
}

type UnknownAPIKeyError struct {
	Id *Id
}

type UnknownAccountError struct {
	Id Id
}

type UnknownConnectorDefError struct {
	Name string
}

type UnknownEventDefError struct {
	Connector string
	Name      string
}

type UnknownEventError struct {
	Id Id
}

type UnknownIdentityDefError struct {
	Connector string
	Type      string
}

type UnknownIdentityError struct {
	Id Id
}

type UnknownIdentityNameError struct {
	Name string
}

type UnknownJobError struct {
	Id Id
}

type UnknownJobExecutionError struct {
	Id Id
}

type UnknownJobNameError struct {
	Name string
}

type UnknownJobSubscriptionError struct {
	JobId Id
}

type UnknownProjectError struct {
	Id Id
}

type UnknownProjectNameError struct {
	Name string
}

type UnknownSessionError struct {
	Id Id
}

type UnknownStepExecutionError struct {
	Id Id
}

type UnknownSubscriptionError struct {
	Id Id
}

type UnknownUsernameError struct {
	Username string
}

type Worker struct {
	Name string
	Cfg  WorkerCfg
	Log  *log.Logger
	Pg   *pg.Client
	// contains filtered or unexported fields
}

type WorkerBehaviour interface {
	Init(*Worker)
	Start() error
	Stop()
	ProcessJob() (bool, error)
}

type WorkerCfg struct {
	Log *log.Logger `json:"-"`
	Pg  *pg.Client  `json:"-"`

	Behaviour WorkerBehaviour `json:"-"`

	Disabled bool `json:"disabled"`

	InitialDelay  int `json:"initial_delay"`  // millisecond
	ErrorDelay    int `json:"error_delay"`    // millisecond
	SleepDuration int `json:"sleep_duration"` // millisecond

	NotificationChan chan<- interface{} `json:"-"`
	StopChan         <-chan struct{}    `json:"-"`
	Wg               *sync.WaitGroup    `json:"-"`
}