eventline

package

Go to main page

Versions in this module

v1

v1.1.0

Nov 4, 2023

Changes in this version

type AccountPasswordUpdate

+ func (au *AccountPasswordUpdate) ValidateJSON(v *ejson.Validator)

type AccountSelfUpdate

+ func (au *AccountSelfUpdate) ValidateJSON(v *ejson.Validator)

type AccountSettings

+ func (as *AccountSettings) ValidateJSON(v *ejson.Validator)

type AccountUpdate

+ func (au *AccountUpdate) ValidateJSON(v *ejson.Validator)

type CommandData

+ func (d *CommandData) ValidateJSON(v *ejson.Validator)

type ConnectorInitData

+ Pg *pg.Client

type Filter

+ func (f *Filter) ValidateJSON(v *ejson.Validator)

type Identity

+ func (i *Identity) LoadByName(conn pg.Conn, name string, scope Scope) error

type Job

+ func (j *Job) UpdateRename(conn pg.Conn, scope Scope) error

+ type JobRenamingData struct

+ Description string

+ Name string

+ func (data *JobRenamingData) ValidateJSON(v *ejson.Validator)

type JobRunner

+ func (r *JobRunner) ValidateJSON(v *ejson.Validator)

type JobSpec

+ func (spec JobSpec) ValidateJSON(v *ejson.Validator)

type NewAPIKey

+ func (nk *NewAPIKey) ValidateJSON(v *ejson.Validator)

type NewAccount

+ func (na *NewAccount) ValidateJSON(v *ejson.Validator)

type NewEvent

+ func (ne *NewEvent) ValidateJSON(v *ejson.Validator)

type NewIdentity

+ func (i *NewIdentity) IsOAuth2() bool

+ func (ni *NewIdentity) ValidateJSON(v *ejson.Validator)

type NewProject

+ func (np *NewProject) ValidateJSON(v *ejson.Validator)

type Parameter

+ func (p *Parameter) ValidateJSON(v *ejson.Validator)

type ProjectSettings

+ func (ps *ProjectSettings) ValidateJSON(v *ejson.Validator)

+ type RawIdentities []*RawIdentity

+ type RawIdentity Identity

+ type RawNewIdentity NewIdentity

type Runner

+ Pg *pg.Client

type RunnerInitData

+ Pg *pg.Client

type Step

+ func (s *Step) ValidateJSON(v *ejson.Validator)

type StepCommand

+ func (s *StepCommand) ValidateJSON(v *ejson.Validator)

type StepScript

+ func (s *StepScript) ValidateJSON(v *ejson.Validator)

type Trigger

+ func (t *Trigger) ValidateJSON(v *ejson.Validator)

+ type UnknownIdentityNameError struct

+ Name string

+ func (err UnknownIdentityNameError) Error() string

type Worker

+ Pg *pg.Client

type WorkerCfg

+ Pg *pg.Client

v1.0.8

Feb 20, 2023

Changes in this version

type Project

+ func LoadMostRecentProject(conn pg.Conn) (*Project, error)

v1.0.7

Nov 7, 2022

Changes in this version

type StepExecutions

+ func (ses *StepExecutions) LoadByJobExecutionIdWithTruncatedOutput(conn pg.Conn, jeId Id, maxOutputSize int, truncationString string) error

v1.0.6

Oct 24, 2022

v1.0.5

Oct 24, 2022

v1.0.4

Oct 24, 2022

v1.0.3

Oct 16, 2022

v1.0.2

Sep 19, 2022

v1.0.1

Sep 13, 2022

v1.0.0

Sep 6, 2022

Changes in this version

+ func DeleteExpiredJobExecutions(conn pg.Conn) (int64, error)

+ func DeleteOldSessions(conn pg.Conn, retention int) (int64, error)

+ func RenderTermData(rawData string) (string, error)

type JobExecution

+ func LoadDeadJobExecution(conn pg.Conn, timeout int) (*JobExecution, error)

+ func (je *JobExecution) LoadForUpdateNoScope(conn pg.Conn, id Id) error

+ func (je *JobExecution) UpdateRefreshTime(conn pg.Conn) error

+ type JobSpecs []*JobSpec

type ProjectNotificationSettings

+ func (ps *ProjectNotificationSettings) CheckEmailAddresses(c *check.Checker, allowedDomains []string)

type Runner

+ func (r *Runner) StepCommandString(se *StepExecution, s *Step, rootPath string) string

type RunnerInitData

+ RefreshInterval time.Duration

v0

v0.9.1

Jul 29, 2022

v0.9.0

Jul 19, 2022

Changes in this version

+ const DefaultCursorSize

+ const DefaultSort

+ const MaxCursorSize

+ const MaxDescriptionLength

+ const MaxLabelLength

+ const MaxNameLength

+ const MaxPageSize

+ const MaxPasswordLength

+ const MaxUsernameLength

+ const MinCursorSize

+ const MinDescriptionLength

+ const MinLabelLength

+ const MinNameLength

+ const MinPageSize

+ const MinPasswordLength

+ const MinUsernameLength

+ const NbPBKDF2Iterations

+ const SaltSize

+ var AccountRoleValues = []AccountRole

+ var Connectors = map[string]Connector

+ var DateFormatValues = []DateFormat

+ var GlobalEncryptionKey dcrypto.AES256Key

+ var JobExecutionStatusValues = []JobExecutionStatus

+ var NameRE = regexp.MustCompile(`^[a-z0-9][a-z0-9\-_]*$`)

+ var ParameterTypeValues = []ParameterType

+ var RunnerDefs = map[string]*RunnerDef

+ var StepExecutionStatusValues = []StepExecutionStatus

+ var StepFailureActionValues = []StepFailureAction

+ var TemplateFuncMap = map[string]interface

+ var ZeroId = ksuid.Zero

+ func APIKeyNameExists(conn pg.Conn, name string, scope Scope) (bool, error)

+ func CheckConnectorName(c *check.Checker, token string, cname string) bool

+ func CheckDescription(c *check.Checker, token string, label string)

+ func CheckEventName(c *check.Checker, token string, cname, name string) bool

+ func CheckEventRef(c *check.Checker, token string, ref EventRef) bool

+ func CheckIdentityName(c *check.Checker, token string, cname, itype string)

+ func CheckLabel(c *check.Checker, token string, label string)

+ func CheckName(c *check.Checker, token interface{}, name string)

+ func ConnectorExists(name string) (exists bool)

+ func CountStartedJobExecutions(conn pg.Conn, scope Scope) (int64, error)

+ func DecryptAES256(data []byte) ([]byte, error)

+ func DeleteAccount(conn pg.Conn, accountId Id) error

+ func DeleteFavouriteJob(conn pg.Conn, jobId Id, scope Scope) error

+ func DeleteJobs(conn pg.Conn, scope Scope) error

+ func EncryptAES256(data []byte) ([]byte, error)

+ func EventDefExists(ref EventRef) bool

+ func EventExists(cname, name string) bool

+ func GenerateSalt() []byte

+ func HashAPIKey(key string) []byte

+ func HashPassword(password string, salt []byte) []byte

+ func IdentityExists(cname, itype string) bool

+ func IdentityNameExists(conn pg.Conn, name string, scope Scope) (bool, error)

+ func IsJobAbortedError(err error) bool

+ func JSONFields(value interface{}) (map[string]string, error)

+ func LoadHTMLTemplates(dirPath string) (*htmltemplate.Template, error)

+ func LoadJobNamesById(conn pg.Conn, ids Ids) (map[Id]string, error)

+ func LoadJobStats(conn pg.Conn, jobIds Ids, scope Scope) (map[Id]*JobStats, error)

+ func LoadLastJobExecutions(conn pg.Conn, jobIds Ids, scope Scope) (map[Id]*JobExecution, error)

+ func LoadTextTemplates(dirPath string) (*texttemplate.Template, error)

+ func ProjectNameExists(conn pg.Conn, name string) (bool, error)

+ func ReversePageElements(elts []PageElement)

+ func StartsWithShebang(data string) bool

+ func SubscriptionParametersEqual(sp1, sp2 SubscriptionParameters) bool

+ func UpdateAccountLastProjectId(conn pg.Conn, accountId Id, projectId *Id) error

+ func UpdateAccountsForProjectDeletion(conn pg.Conn, projectId Id) error

+ func UpdateSessionsForProjectDeletion(conn pg.Conn, projectId Id) error

+ func UsernameExists(conn pg.Conn, username string) (bool, error)

+ func ValidateConnectorName(name string) error

+ type APIKey struct

+ AccountId Id

+ CreationTime time.Time

+ Id Id

+ KeyHash []byte

+ LastUseTime *time.Time

+ Name string

+ func (k *APIKey) Delete(conn pg.Conn, scope Scope) error

+ func (k *APIKey) FromRow(row pgx.Row) error

+ func (k *APIKey) Insert(conn pg.Conn) error

+ func (k *APIKey) LoadForUpdate(conn pg.Conn, id Id, scope Scope) error

+ func (k *APIKey) LoadUpdateByKeyHash(conn pg.Conn, keyHash []byte) error

+ func (k *APIKey) SortKey(sort string) (key string)

+ type APIKeys []*APIKey

+ func (ks *APIKeys) AddFromRow(row pgx.Row) error

+ func (ks APIKeys) Page(cursor *Cursor) *Page

+ type Account struct

+ CreationTime time.Time

+ Id Id

+ LastLoginTime *time.Time

+ LastProjectId *Id

+ PasswordHash []byte

+ Role AccountRole

+ Salt []byte

+ Settings *AccountSettings

+ Username string

+ func (a *Account) CheckPassword(password string) bool

+ func (a *Account) FromRow(row pgx.Row) error

+ func (a *Account) Insert(conn pg.Conn) error

+ func (a *Account) Load(conn pg.Conn, id Id) error

+ func (a *Account) LoadByUsernameForUpdate(conn pg.Conn, username string) error

+ func (a *Account) LoadForUpdate(conn pg.Conn, id Id) error

+ func (a *Account) SelfUpdate(conn pg.Conn) error

+ func (a *Account) SortKey(sort string) (key string)

+ func (a *Account) Update(conn pg.Conn) error

+ func (a *Account) UpdateForLogin(conn pg.Conn) error

+ type AccountPasswordUpdate struct

+ Password string

+ PasswordConfirmation string

+ func (au *AccountPasswordUpdate) Check(c *check.Checker)

+ type AccountProjectScope struct

+ AccountId Id

+ ProjectId Id

+ func (scope *AccountProjectScope) SQLCondition() string

+ func (scope *AccountProjectScope) SQLCondition2(correlation string) string

+ type AccountRole string

+ const AccountRoleAdmin

+ const AccountRoleUser

+ type AccountScope struct

+ AccountId Id

+ func (scope *AccountScope) SQLCondition() string

+ func (scope *AccountScope) SQLCondition2(correlation string) string

+ type AccountSelfUpdate struct

+ Settings *AccountSettings

+ func (au *AccountSelfUpdate) Check(c *check.Checker)

+ type AccountSettings struct

+ DateFormat DateFormat

+ PageSize int

+ func DefaultAccountSettings() *AccountSettings

+ func (as *AccountSettings) Check(c *check.Checker)

+ type AccountUpdate struct

+ Role AccountRole

+ Username string

+ func (au *AccountUpdate) Check(c *check.Checker)

+ type Accounts []*Account

+ func (as *Accounts) AddFromRow(row pgx.Row) error

+ func (as *Accounts) LoadAll(conn pg.Conn) error

+ func (as Accounts) Page(cursor *Cursor) *Page

+ type CommandData struct

+ Parameters []*Parameter

+ Pipelines []string

+ func (d *CommandData) Check(c *check.Checker)

+ type Connector interface

+ DefaultCfg func() ConnectorCfg

+ Definition func() *ConnectorDef

+ Init func(ConnectorCfg, ConnectorInitData) error

+ Name func() string

+ Terminate func()

+ func FindConnector(name string) (Connector, bool)

+ func GetConnector(name string) Connector

+ type ConnectorCfg interface

+ type ConnectorDef struct

+ Events map[string]*EventDef

+ Identities map[string]*IdentityDef

+ Name string

+ Worker WorkerBehaviour

+ func GetConnectorDef(name string) *ConnectorDef

+ func NewConnectorDef(name string) *ConnectorDef

+ func (c *ConnectorDef) AddEvent(edef *EventDef)

+ func (c *ConnectorDef) AddIdentity(idef *IdentityDef)

+ func (c *ConnectorDef) Event(typeName string) *EventDef

+ func (c *ConnectorDef) EventExists(typeName string) (exists bool)

+ func (c *ConnectorDef) Identity(typeName string) *IdentityDef

+ func (c *ConnectorDef) IdentityExists(typeName string) (exists bool)

+ func (c *ConnectorDef) ValidateEventName(name string) error

+ func (c *ConnectorDef) ValidateIdentityType(typeName string) error

+ type ConnectorInitData struct

+ Daemon *daemon.Daemon

+ Log *log.Logger

+ WebHTTPServerURI *url.URL

+ type Cursor struct

+ After string

+ Before string

+ Order Order

+ Size int

+ Sort string

+ func (c *Cursor) Query() url.Values

+ func (c *Cursor) SQLConditionOrderLimit(sorts Sorts) string

+ func (c *Cursor) SQLConditionOrderLimit2(sorts Sorts, correlation string) string

+ func (c *Cursor) URL() *url.URL

+ func (pc *Cursor) ParseQuery(query url.Values, sorts Sorts, accountSettings *AccountSettings) error

+ type DateFormat string

+ const DateFormatAbsolute

+ const DateFormatRelative

+ type Event struct

+ Connector string

+ CreationTime time.Time

+ Data EventData

+ DataValue interface{}

+ EventTime time.Time

+ Id Id

+ JobId *Id

+ Name string

+ OriginalEventId *Id

+ Processed bool

+ ProjectId Id

+ func LoadEventForProcessing(conn pg.Conn) (*Event, error)

+ func (e *Event) Def() *EventDef

+ func (e *Event) FromRow(row pgx.Row) error

+ func (e *Event) Insert(conn pg.Conn) error

+ func (e *Event) Load(conn pg.Conn, id Id, scope Scope) error

+ func (e *Event) SortKey(sort string) (key string)

+ func (e *Event) Update(conn pg.Conn) error

+ type EventData interface

+ type EventDef struct

+ Data EventData

+ Name string

+ SubscriptionParameters SubscriptionParameters

+ func GetEventDef(ref EventRef) *EventDef

+ func NewEventDef(name string, data EventData, subscriptionParameters SubscriptionParameters) *EventDef

+ func (edef *EventDef) DecodeData(data []byte) (EventData, error)

+ func (edef *EventDef) DecodeSubscriptionParameters(data []byte) (SubscriptionParameters, error)

+ type EventRef struct

+ Connector string

+ Event string

+ func (ref *EventRef) Parse(s string) error

+ func (ref *EventRef) UnmarshalJSON(data []byte) error

+ func (ref EventRef) MarshalJSON() ([]byte, error)

+ func (ref EventRef) String() string

+ type Events []*Event

+ func (es Events) Page(cursor *Cursor) *Page

+ func (is *Events) AddFromRow(row pgx.Row) error

+ type ExecutionContext struct

+ Event *Event

+ Identities map[string]*Identity

+ Parameters map[string]interface{}

+ func (ctx *ExecutionContext) Encode() ([]byte, error)

+ func (ctx *ExecutionContext) Load(conn pg.Conn, je *JobExecution) error

+ func (ctx *ExecutionContext) Write(w io.Writer) error

+ type ExternalSubscriptionError struct

+ Err error

+ func NewExternalSubscriptionError(err error) *ExternalSubscriptionError

+ func (err ExternalSubscriptionError) Error() string

+ type FavouriteJob struct

+ AccountId Id

+ JobId Id

+ ProjectId Id

+ func (fj *FavouriteJob) Upsert(conn pg.Conn) error

+ type FileSet struct

+ Files map[string]*FileSetFile

+ func NewFileSet() *FileSet

+ func (s *FileSet) AddFile(filePath string, content []byte, mode os.FileMode)

+ func (s *FileSet) AddPrefix(prefix string)

+ func (s *FileSet) TarArchive(buf *bytes.Buffer) error

+ func (s *FileSet) Write(rootPath string) error

+ type FileSetFile struct

+ Content []byte

+ Mode os.FileMode

+ type Filter struct

+ DoesNotMatch string

+ DoesNotMatchRE *regexp.Regexp

+ IsEqualTo interface{}

+ IsNotEqualTo interface{}

+ Matches string

+ MatchesRE *regexp.Regexp

+ Path djson.Pointer

+ func (f *Filter) Check(c *check.Checker)

+ func (f *Filter) Match(obj interface{}) bool

+ func (pf *Filter) MarshalJSON() ([]byte, error)

+ type Filters []*Filter

+ func (fs Filters) Match(obj interface{}) bool

+ type GlobalScope struct

+ func NewGlobalScope() *GlobalScope

+ func (scope *GlobalScope) SQLCondition() string

+ func (scope *GlobalScope) SQLCondition2(correlation string) string

+ type Id = ksuid.KSUID

+ func GenerateId() Id

+ func LoadIdentityIdByName(conn pg.Conn, name string, scope Scope) (Id, error)

+ type Identities []*Identity

+ func (is *Identities) AddFromRow(row pgx.Row) error

+ func (is *Identities) LoadAllForUpdate(conn pg.Conn, scope Scope) error

+ func (is *Identities) LoadByNames(conn pg.Conn, names []string, scope Scope) error

+ func (is *Identities) LoadByNamesForUpdate(conn pg.Conn, names []string, scope Scope) error

+ func (is Identities) Page(cursor *Cursor) *Page

+ type Identity struct

+ Connector string

+ CreationTime time.Time

+ Data IdentityData

+ ErrorMessage string

+ Id Id

+ LastUseTime *time.Time

+ Name string

+ ProjectId *Id

+ RawData json.RawMessage

+ RefreshTime *time.Time

+ Status IdentityStatus

+ Type string

+ UpdateTime time.Time

+ func LoadIdentityForRefresh(conn pg.Conn) (*Identity, error)

+ func (i *Identity) Delete(conn pg.Conn) error

+ func (i *Identity) FromRow(row pgx.Row) error

+ func (i *Identity) Insert(conn pg.Conn) error

+ func (i *Identity) IsUsed(conn pg.Conn, scope Scope) (bool, error)

+ func (i *Identity) IsUsedByJob(conn pg.Conn, scope Scope) (bool, error)

+ func (i *Identity) IsUsedBySubscription(conn pg.Conn) (bool, error)

+ func (i *Identity) Load(conn pg.Conn, id Id, scope Scope) error

+ func (i *Identity) LoadForUpdate(conn pg.Conn, id Id, scope Scope) error

+ func (i *Identity) Refreshable() bool

+ func (i *Identity) SortKey(sort string) (key string)

+ func (i *Identity) Update(conn pg.Conn) error

+ func (i *Identity) UpdateForProjectDeletion(conn pg.Conn) error

+ func (i *Identity) UpdateLastUseTime(conn pg.Conn) error

+ func (pi *Identity) MarshalJSON() ([]byte, error)

+ func (pi *Identity) UnmarshalJSON(data []byte) error

+ type IdentityData interface

+ Def func() *IdentityDataDef

+ Environment func() map[string]string

+ type IdentityDataDef struct

+ Entries []*IdentityDataEntry

+ func NewIdentityDataDef() *IdentityDataDef

+ func (v *IdentityDataDef) AddEntry(e *IdentityDataEntry)

+ type IdentityDataEntry struct

+ EnumValues []string

+ Internal bool

+ Key string

+ Label string

+ MultiselectEnumSize int

+ Optional bool

+ PreselectedEnumValues []string

+ Secret bool

+ Type IdentityDataType

+ Value interface{}

+ Verbatim bool

+ type IdentityDataType string

+ const IdentityDataTypeBoolean

+ const IdentityDataTypeDate

+ const IdentityDataTypeEnum

+ const IdentityDataTypeEnumList

+ const IdentityDataTypeString

+ const IdentityDataTypeStringList

+ const IdentityDataTypeTextBlock

+ const IdentityDataTypeURI

+ type IdentityDef struct

+ Data IdentityData

+ DataDef *IdentityDataDef

+ DeferredReadiness bool

+ Refreshable bool

+ Type string

+ func NewIdentityDef(typeName string, dataValue IdentityData) *IdentityDef

+ func (idef *IdentityDef) DecodeData(data []byte) (IdentityData, error)

+ func (idef *IdentityDef) IsOAuth2() bool

+ type IdentityStatus string

+ const IdentityStatusError

+ const IdentityStatusPending

+ const IdentityStatusReady

+ type Ids = ksuid.KSUIDs

+ type Job struct

+ CreationTime time.Time

+ Disabled bool

+ Id Id

+ ProjectId Id

+ Spec *JobSpec

+ UpdateTime time.Time

+ func (j *Job) Delete(conn pg.Conn, scope Scope) error

+ func (j *Job) FromRow(row pgx.Row) error

+ func (j *Job) Load(conn pg.Conn, id Id, scope Scope) error

+ func (j *Job) LoadByName(conn pg.Conn, name string, scope Scope) error

+ func (j *Job) LoadForUpdate(conn pg.Conn, id Id, scope Scope) error

+ func (j *Job) LoadRunningTimes(conn pg.Conn, params *MetricParameters) (MetricPoints, error)

+ func (j *Job) LoadStatusCounts(conn pg.Conn, params *MetricParameters) (MetricPoints, error)

+ func (j *Job) SortKey(sort string) (key string)

+ func (j *Job) Update(conn pg.Conn, scope Scope) error

+ func (j *Job) Upsert(conn pg.Conn) (Id, error)

+ type JobExecution struct

+ CreationTime time.Time

+ EndTime *time.Time

+ EventId *Id

+ ExpirationTime *time.Time

+ FailureMessage string

+ Id Id

+ JobId Id

+ JobSpec *JobSpec

+ Parameters map[string]interface{}

+ ProjectId Id

+ RefreshTime *time.Time

+ ScheduledTime time.Time

+ StartTime *time.Time

+ Status JobExecutionStatus

+ UpdateTime time.Time

+ func LoadJobExecutionForScheduling(conn pg.Conn) (*JobExecution, error)

+ func LoadLastJobExecutionFinishedBefore(conn pg.Conn, je *JobExecution) (*JobExecution, error)

+ func (je *JobExecution) Duration() *time.Duration

+ func (je *JobExecution) Finished() bool

+ func (je *JobExecution) FromRow(row pgx.Row) error

+ func (je *JobExecution) Insert(conn pg.Conn) error

+ func (je *JobExecution) Load(conn pg.Conn, id Id, scope Scope) error

+ func (je *JobExecution) LoadForUpdate(conn pg.Conn, id Id, scope Scope) error

+ func (je *JobExecution) LoadNoScope(conn pg.Conn, id Id) error

+ func (je *JobExecution) SortKey(sort string) (key string)

+ func (je *JobExecution) Update(conn pg.Conn) error

+ type JobExecutionAbortedError struct

+ Id Id

+ func (err *JobExecutionAbortedError) Error() string

+ type JobExecutionFinishedError struct

+ Id Id

+ func (err *JobExecutionFinishedError) Error() string

+ type JobExecutionInput struct

+ Parameters map[string]interface{}

+ RawParameters json.RawMessage

+ func (pi *JobExecutionInput) MarshalJSON() ([]byte, error)

+ func (pi *JobExecutionInput) UnmarshalJSON(data []byte) error

+ type JobExecutionNotFinishedError struct

+ Id Id

+ func (err *JobExecutionNotFinishedError) Error() string

+ type JobExecutionPageOptions struct

+ JobId *Id

+ type JobExecutionStatus string

+ const JobExecutionStatusAborted

+ const JobExecutionStatusCreated

+ const JobExecutionStatusFailed

+ const JobExecutionStatusStarted

+ const JobExecutionStatusSuccessful

+ type JobExecutions []*JobExecution

+ func (jes *JobExecutions) AddFromRow(row pgx.Row) error

+ func (jes *JobExecutions) LoadByEvent(conn pg.Conn, eventId Id) error

+ func (jes JobExecutions) Page(cursor *Cursor) *Page

+ type JobPageOptions struct

+ ExcludeFavouriteJobAccountId *Id

+ type JobRunner struct

+ Identity string

+ Name string

+ Parameters RunnerParameters

+ RawParameters json.RawMessage

+ func (pr *JobRunner) MarshalJSON() ([]byte, error)

+ func (pr *JobRunner) UnmarshalJSON(data []byte) error

+ func (r *JobRunner) Check(c *check.Checker)

+ type JobSpec struct

+ Concurrent bool

+ Description string

+ Environment map[string]string

+ Identities []string

+ Name string

+ Parameters Parameters

+ Retention int

+ Runner *JobRunner

+ Steps Steps

+ Trigger *Trigger

+ func (spec *JobSpec) IdentityNames() []string

+ func (spec *JobSpec) ParseYAML(data []byte) error

+ func (spec JobSpec) Check(c *check.Checker)

+ type JobStats struct

+ DurationP50 *time.Duration

+ JobId Id

+ NbExecutions int

+ SuccessRatio float64

+ func (js *JobStats) FromRow(row pgx.Row) error

+ func (js *JobStats) SuccessPercentage() float64

+ func (js *JobStats) SuccessPercentageString() string

+ type JobStatsList []*JobStats

+ func (jss *JobStatsList) AddFromRow(row pgx.Row) error

+ type Jobs []*Job

+ func LoadFavouriteJobs(conn pg.Conn, scope Scope) (Jobs, error)

+ func (js *Jobs) AddFromRow(row pgx.Row) error

+ func (js *Jobs) LoadByIdentityName(conn pg.Conn, name string, scope Scope) error

+ func (js Jobs) Page(cursor *Cursor) *Page

+ type MetricGranularity string

+ const MetricGranularityDay

+ const MetricGranularityHour

+ type MetricParameters struct

+ End time.Time

+ Granularity MetricGranularity

+ Start time.Time

+ type MetricPoint []interface

+ func (p *MetricPoint) FromRow(row pgx.Row) error

+ type MetricPoints []MetricPoint

+ func (ps *MetricPoints) AddFromRow(row pgx.Row) error

+ type NewAPIKey struct

+ Name string

+ func (nk *NewAPIKey) Check(c *check.Checker)

+ type NewAccount struct

+ Password string

+ PasswordConfirmation string

+ Role AccountRole

+ Username string

+ func (na *NewAccount) Check(c *check.Checker)

+ type NewEvent struct

+ Connector string

+ Data EventData

+ EventTime time.Time

+ Name string

+ RawData json.RawMessage

+ func (ne *NewEvent) Check(c *check.Checker)

+ func (pne *NewEvent) UnmarshalJSON(data []byte) error

+ type NewIdentity struct

+ Connector string

+ Data IdentityData

+ Name string

+ RawData json.RawMessage

+ Type string

+ func (ni *NewIdentity) Check(c *check.Checker)

+ func (pni *NewIdentity) MarshalJSON() ([]byte, error)

+ func (pni *NewIdentity) UnmarshalJSON(data []byte) error

+ type NewProject struct

+ Name string

+ func (np *NewProject) Check(c *check.Checker)

+ type NewSession struct

+ AccountRole AccountRole

+ AccountSettings *AccountSettings

+ Data *SessionData

+ type Notification struct

+ DeliveryDelay int

+ Id Id

+ Message []byte

+ NextDeliveryTime time.Time

+ ProjectId Id

+ Recipients []string

+ func LoadNotificationForDelivery(conn pg.Conn) (*Notification, error)

+ func (n *Notification) Delete(conn pg.Conn) error

+ func (n *Notification) FromRow(row pgx.Row) error

+ func (n *Notification) Insert(conn pg.Conn) error

+ func (n *Notification) Update(conn pg.Conn) error

+ type NullProjectScope struct

+ func (scope *NullProjectScope) SQLCondition() string

+ func (scope *NullProjectScope) SQLCondition2(correlation string) string

+ type OAuth2IdentityData interface

+ FetchTokenData func(*http.Client, string, string) error

+ RedirectionURI func(*http.Client, string, string) (string, error)

+ type OptionalConnector interface

+ Enabled func() bool

+ type Order string

+ const OrderAsc

+ const OrderDesc

+ type Page struct

+ Elements []PageElement

+ Next *Cursor

+ Previous *Cursor

+ func LoadAPIKeyPage(conn pg.Conn, cursor *Cursor, scope Scope) (*Page, error)

+ func LoadAccountPage(conn pg.Conn, cursor *Cursor) (*Page, error)

+ func LoadEventPage(conn pg.Conn, cursor *Cursor, scope Scope) (*Page, error)

+ func LoadIdentityPage(conn pg.Conn, cursor *Cursor, scope Scope) (*Page, error)

+ func LoadJobExecutionPage(conn pg.Conn, options JobExecutionPageOptions, cursor *Cursor, scope Scope) (*Page, error)

+ func LoadJobPage(conn pg.Conn, options JobPageOptions, cursor *Cursor, scope Scope) (*Page, error)

+ func LoadProjectPage(conn pg.Conn, cursor *Cursor) (*Page, error)

+ func NewPage(cursor *Cursor, elements []PageElement, sorts Sorts) *Page

+ func (p *Page) HasPreviousOrNextURI() bool

+ func (p *Page) IsEmpty() bool

+ func (p *Page) NextURI() string

+ func (p *Page) PreviousURI() string

+ type PageElement interface

+ SortKey func(string) string

+ type Parameter struct

+ Default interface{}

+ Description string

+ Environment string

+ Name string

+ RawDefault json.RawMessage

+ Type ParameterType

+ Values []string

+ func (p *Parameter) Check(c *check.Checker)

+ func (p *Parameter) CheckValue(c *check.Checker, token string, value interface{}) interface{}

+ func (p *Parameter) Label() string

+ func (p *Parameter) ValueString(value interface{}) (s string)

+ func (pp *Parameter) MarshalJSON() ([]byte, error)

+ func (pp *Parameter) UnmarshalJSON(data []byte) error

+ type ParameterType string

+ const ParameterTypeBoolean

+ const ParameterTypeInteger

+ const ParameterTypeNumber

+ const ParameterTypeString

+ type Parameters []*Parameter

+ func (ps Parameters) CheckValues(c *check.Checker, token string, values map[string]interface{})

+ func (ps Parameters) Parameter(name string) *Parameter

+ type Project struct

+ CreationTime time.Time

+ Id Id

+ Name string

+ UpdateTime time.Time

+ func (p *Project) Delete(conn pg.Conn) error

+ func (p *Project) FromRow(row pgx.Row) error

+ func (p *Project) Insert(conn pg.Conn) error

+ func (p *Project) Load(conn pg.Conn, id Id) error

+ func (p *Project) LoadByName(conn pg.Conn, name string) error

+ func (p *Project) LoadForUpdate(conn pg.Conn, id Id) error

+ func (p *Project) SortKey(sort string) (key string)

+ func (p *Project) Update(conn pg.Conn) error

+ type ProjectNotificationSettings struct

+ EmailAddresses []string

+ Id Id

+ OnAbortedJob bool

+ OnFailedJob bool

+ OnFirstSuccessfulJob bool

+ OnIdentityRefreshError bool

+ OnSuccessfulJob bool

+ func (ps *ProjectNotificationSettings) Check(c *check.Checker)

+ func (ps *ProjectNotificationSettings) FromRow(row pgx.Row) error

+ func (ps *ProjectNotificationSettings) Insert(conn pg.Conn) error

+ func (ps *ProjectNotificationSettings) Load(conn pg.Conn, id Id) error

+ func (ps *ProjectNotificationSettings) Update(conn pg.Conn) error

+ type ProjectScope struct

+ ProjectId Id

+ func (scope *ProjectScope) SQLCondition() string

+ func (scope *ProjectScope) SQLCondition2(correlation string) string

+ type ProjectSettings struct

+ CodeHeader string

+ Id Id

+ func (ps *ProjectSettings) Check(c *check.Checker)

+ func (ps *ProjectSettings) FromRow(row pgx.Row) error

+ func (ps *ProjectSettings) Insert(conn pg.Conn) error

+ func (ps *ProjectSettings) Load(conn pg.Conn, id Id) error

+ func (ps *ProjectSettings) Update(conn pg.Conn) error

+ type Projects []*Project

+ func (ps *Projects) AddFromRow(row pgx.Row) error

+ func (ps *Projects) LoadAll(conn pg.Conn) error

+ func (ps Projects) Page(cursor *Cursor) *Page

+ type RefreshableOAuth2IdentityData interface

+ Refresh func(*http.Client) error

+ RefreshTime func() time.Time

+ type Runner struct

+ Behaviour RunnerBehaviour

+ Cfg RunnerCfg

+ Daemon *daemon.Daemon

+ Environment map[string]string

+ ExecutionContext *ExecutionContext

+ FileSet *FileSet

+ JobExecution *JobExecution

+ Log *log.Logger

+ Project *Project

+ ProjectSettings *ProjectSettings

+ RunnerIdentity *Identity

+ Scope Scope

+ StepExecutions StepExecutions

+ StopChan <-chan struct{}

+ Wg *sync.WaitGroup

+ func NewRunner(data RunnerInitData) (*Runner, error)

+ func (r *Runner) HandleError(err error)

+ func (r *Runner) HandleInterruption()

+ func (r *Runner) Start() error

+ func (r *Runner) StepCommand(se *StepExecution, s *Step, rootPath string) (name string, args []string)

+ func (r *Runner) Stopping() bool

+ func (r *Runner) UpdateStepExecutionOutput(se *StepExecution, data []byte) error

+ type RunnerBehaviour interface

+ DirPath func() string

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

+ Init func(ctx context.Context) error

+ Terminate func()

+ type RunnerCfg interface

+ type RunnerData struct

+ ExecutionContext *ExecutionContext

+ JobExecution *JobExecution

+ Project *Project

+ ProjectSettings *ProjectSettings

+ StepExecutions StepExecutions

+ func (rd *RunnerData) Environment() map[string]string

+ func (rd *RunnerData) FileSet() (*FileSet, error)

+ type RunnerDef struct

+ Cfg RunnerCfg

+ InstantiateBehaviour func(*Runner) RunnerBehaviour

+ InstantiateParameters func() RunnerParameters

+ Name string

+ type RunnerInitData struct

+ Cfg RunnerCfg

+ Daemon *daemon.Daemon

+ Data *RunnerData

+ Def *RunnerDef

+ Log *log.Logger

+ StopChan <-chan struct{}

+ TerminationChan chan<- Id

+ Wg *sync.WaitGroup

+ type RunnerParameters interface

+ type Scope interface

+ SQLCondition func() string

+ SQLCondition2 func(string) string

+ func NewAccountProjectScope(accountId, projectId Id) Scope

+ func NewAccountScope(accountId Id) Scope

+ func NewNullProjectScope() Scope

+ func NewProjectScope(projectId Id) Scope

+ type Session struct

+ AccountId Id

+ AccountRole AccountRole

+ AccountSettings *AccountSettings

+ CreationTime time.Time

+ Data *SessionData

+ Id Id

+ UpdateTime time.Time

+ func (s *Session) Delete(conn pg.Conn) error

+ func (s *Session) FromRow(row pgx.Row) error

+ func (s *Session) Insert(conn pg.Conn) error

+ func (s *Session) LoadUpdate(conn pg.Conn, id Id) error

+ func (s *Session) UpdateAccountSettings(conn pg.Conn) error

+ func (s *Session) UpdateData(conn pg.Conn) error

+ type SessionData struct

+ ProjectId *Id

+ type Shebang struct

+ Argument string

+ Interpreter string

+ func (s *Shebang) Parse(data string) error

+ type Sorts struct

+ Default string

+ Sorts map[string]string

+ var APIKeySorts Sorts = Sorts{ ... }

+ var AccountSorts Sorts = Sorts{ ... }

+ var DefaultSorts Sorts = Sorts{ ... }

+ var EventSorts Sorts = Sorts{ ... }

+ var IdentitySorts Sorts = Sorts{ ... }

+ var JobExecutionSorts Sorts = Sorts{ ... }

+ var JobSorts Sorts = Sorts{ ... }

+ var ProjectSorts Sorts = Sorts{ ... }

+ func (ss Sorts) Column(name string) string

+ func (ss Sorts) Contains(name string) bool

+ type Step struct

+ Code string

+ Command *StepCommand

+ Label string

+ OnFailure StepFailureAction

+ Script *StepScript

+ func (s *Step) AbortOnFailure() bool

+ func (s *Step) Check(c *check.Checker)

+ type StepCommand struct

+ Arguments []string

+ Name string

+ func (s *StepCommand) Check(c *check.Checker)

+ type StepExecution struct

+ EndTime *time.Time

+ FailureMessage string

+ Id Id

+ JobExecutionId Id

+ Output string

+ Position int

+ ProjectId Id

+ StartTime *time.Time

+ Status StepExecutionStatus

+ func (se *StepExecution) ClearOutput(conn pg.Conn) error

+ func (se *StepExecution) Duration() *time.Duration

+ func (se *StepExecution) Finished() bool

+ func (se *StepExecution) FromRow(row pgx.Row) error

+ func (se *StepExecution) Insert(conn pg.Conn) error

+ func (se *StepExecution) Load(conn pg.Conn, id Id, scope Scope) error

+ func (se *StepExecution) Update(conn pg.Conn) error

+ func (se *StepExecution) UpdateOutput(conn pg.Conn, data []byte) error

+ type StepExecutionStatus string

+ const StepExecutionStatusAborted

+ const StepExecutionStatusCreated

+ const StepExecutionStatusFailed

+ const StepExecutionStatusStarted

+ const StepExecutionStatusSuccessful

+ type StepExecutions []*StepExecution

+ func (ses *StepExecutions) AddFromRow(row pgx.Row) error

+ func (ses *StepExecutions) LoadByJobExecutionId(conn pg.Conn, jeId Id) error

+ func (ses *StepExecutions) LoadByJobExecutionIdForUpdate(conn pg.Conn, jeId Id) error

+ type StepFailureAction string

+ const StepFailureActionAbort

+ const StepFailureActionContinue

+ type StepFailureError struct

+ func NewStepFailureError(err error) *StepFailureError

+ func (err *StepFailureError) Error() string

+ func (err *StepFailureError) Unwrap() error

+ type StepScript struct

+ Arguments []string

+ Content string

+ Path string

+ func (s *StepScript) Check(c *check.Checker)

+ type Steps []*Step

+ type SubscribableConnector interface

+ Subscribe func(pg.Conn, *SubscriptionContext) error

+ Unsubscribe func(pg.Conn, *SubscriptionContext) error

+ type Subscription struct

+ Connector string

+ CreationTime time.Time

+ Event string

+ Id Id

+ IdentityId *Id

+ JobId *Id

+ LastUpdateTime *time.Time

+ NextUpdateTime *time.Time

+ Parameters SubscriptionParameters

+ ProjectId *Id

+ Status SubscriptionStatus

+ UpdateDelay int

+ func LoadSubscriptionForProcessing(conn pg.Conn) (*Subscription, error)

+ func (s *Subscription) Delete(conn pg.Conn) error

+ func (s *Subscription) EventDef() *EventDef

+ func (s *Subscription) FromRow(row pgx.Row) error

+ func (s *Subscription) Insert(conn pg.Conn) error

+ func (s *Subscription) Load(conn pg.Conn, id Id) error

+ func (s *Subscription) LoadByJobForUpdate(conn pg.Conn, jobId Id, scope Scope) error

+ func (s *Subscription) NewEvent(cname, ename string, etime *time.Time, data EventData) *Event

+ func (s *Subscription) Update(conn pg.Conn) error

+ func (s *Subscription) UpdateOp(conn pg.Conn) error

+ type SubscriptionContext struct

+ Identity *Identity

+ Job *Job

+ Scope Scope

+ Subscription *Subscription

+ func (sctx *SubscriptionContext) Load(conn pg.Conn, subscription *Subscription) error

+ type SubscriptionParameters interface

+ type SubscriptionStatus string

+ const SubscriptionStatusActive

+ const SubscriptionStatusInactive

+ const SubscriptionStatusTerminating

+ type Subscriptions []*Subscription

+ func (ss *Subscriptions) AddFromRow(row pgx.Row) error

+ func (ss *Subscriptions) LoadAllForUpdate(conn pg.Conn, scope Scope) error

+ type Trigger struct

+ Event EventRef

+ Filters Filters

+ Identity string

+ Parameters SubscriptionParameters

+ RawParameters json.RawMessage

+ func (pt *Trigger) MarshalJSON() ([]byte, error)

+ func (pt *Trigger) UnmarshalJSON(data []byte) error

+ func (t *Trigger) Check(c *check.Checker)

+ type UnknownAPIKeyError struct

+ Id *Id

+ func (err UnknownAPIKeyError) Error() string

+ type UnknownAccountError struct

+ Id Id

+ func (err UnknownAccountError) Error() string

+ type UnknownConnectorDefError struct

+ Name string

+ func (err UnknownConnectorDefError) Error() string

+ type UnknownEventDefError struct

+ Connector string

+ Name string

+ func (err UnknownEventDefError) Error() string

+ type UnknownEventError struct

+ Id Id

+ func (err UnknownEventError) Error() string

+ type UnknownIdentityDefError struct

+ Connector string

+ Type string

+ func (err UnknownIdentityDefError) Error() string

+ type UnknownIdentityError struct

+ Id Id

+ func (err UnknownIdentityError) Error() string

+ type UnknownJobError struct

+ Id Id

+ func (err UnknownJobError) Error() string

+ type UnknownJobExecutionError struct

+ Id Id

+ func (err UnknownJobExecutionError) Error() string

+ type UnknownJobNameError struct

+ Name string

+ func (err UnknownJobNameError) Error() string

+ type UnknownJobSubscriptionError struct

+ JobId Id

+ func (err UnknownJobSubscriptionError) Error() string

+ type UnknownProjectError struct

+ Id Id

+ func (err UnknownProjectError) Error() string

+ type UnknownProjectNameError struct

+ Name string

+ func (err UnknownProjectNameError) Error() string

+ type UnknownSessionError struct

+ Id Id

+ func (err UnknownSessionError) Error() string

+ type UnknownStepExecutionError struct

+ Id Id

+ func (err UnknownStepExecutionError) Error() string

+ type UnknownSubscriptionError struct

+ Id Id

+ func (err UnknownSubscriptionError) Error() string

+ type UnknownUsernameError struct

+ Username string

+ func (err UnknownUsernameError) Error() string

+ type Worker struct

+ Cfg WorkerCfg

+ Daemon *daemon.Daemon

+ Log *log.Logger

+ Name string

+ func NewWorker(name string, cfg WorkerCfg) *Worker

+ func (w *Worker) Start() error

+ func (w *Worker) Stopping() bool

+ func (w *Worker) WakeUp()

+ type WorkerBehaviour interface

+ Init func(*Worker)

+ ProcessJob func() (bool, error)

+ Start func() error

+ Stop func()

+ type WorkerCfg struct

+ Behaviour WorkerBehaviour

+ Daemon *daemon.Daemon

+ Disabled bool

+ ErrorDelay int

+ InitialDelay int

+ Log *log.Logger

+ NotificationChan chan<- interface{}

+ SleepDuration int

+ StopChan <-chan struct{}

+ Wg *sync.WaitGroup

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL