service

package

Go to main page

Versions in this module

v1

v1.1.2

Sep 10, 2024

v1.1.1

Aug 31, 2024

v1.1.0

Nov 4, 2023

Changes in this version

+ type APIClient struct

+ func NewAPIClient(c *shttp.Client) *APIClient

+ func (c *APIClient) SendJSONRequest(method string, uri *url.URL, header map[string]string, value interface{}) (*http.Response, error)

+ func (c *APIClient) SendRequest(method string, uri *url.URL, header map[string]string, body io.Reader) (*http.Response, error)

+ type APIError struct

+ Code string

+ Data shttp.ErrorData

+ Message string

+ RawData json.RawMessage

+ type APIRequestError struct

+ APIError *APIError

+ Message string

+ Status int

+ func (err APIRequestError) Error() string

type HTTPHandler

+ func (h *HTTPHandler) IdPathVariable(name string) (id eventline.Id, err error)

type HTTPServer

+ func (s *HTTPServer) LoadIdentityByName(h *HTTPHandler, identityName string) (*eventline.Identity, error)

+ func (s *HTTPServer) RenameJob(h *HTTPHandler, jobId eventline.Id, data *eventline.JobRenamingData) error

+ type JobSpecValidator struct

+ Conn pg.Conn

+ Identities map[string]*eventline.Identity

+ JobSpec *eventline.JobSpec

+ Scope eventline.Scope

+ Service *Service

+ Validator *ejson.Validator

type LoginData

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

type NotificationsCfg

+ func (cfg *NotificationsCfg) ValidateJSON(v *ejson.Validator)

type ProjectConfiguration

+ func (cfg *ProjectConfiguration) ValidateJSON(v *ejson.Validator)

type SMTPServerCfg

+ func (cfg *SMTPServerCfg) ValidateJSON(v *ejson.Validator)

type Service

+ Pg *pg.Client

+ Service *goservice.Service

+ func (s *Service) DefaultCfg() interface{}

+ func (s *Service) RenameJob(conn pg.Conn, jobId eventline.Id, data *eventline.JobRenamingData, ...) (*eventline.Job, error)

+ func (s *Service) ValidateCfg() error

type ServiceCfg

+ InsecureHTTPCookies bool

+ ServiceAPI *goservice.ServiceAPICfg

v1.0.8

Feb 20, 2023

v1.0.7

Nov 7, 2022

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

+ const PgAdvisoryLockId2JobDeployment

type HTTPServer

+ func (s *HTTPServer) AbortJobExecution(h *HTTPHandler, jeId eventline.Id) error

+ func (s *HTTPServer) LoadJobExecution(h *HTTPHandler, jeId eventline.Id) (*eventline.JobExecution, error)

+ func (s *HTTPServer) RestartJobExecution(h *HTTPHandler, jeId eventline.Id) error

+ type JobExecutionGC struct

+ Log *dlog.Logger

+ Service *Service

+ func NewJobExecutionGC(s *Service) *JobExecutionGC

+ func (jegc *JobExecutionGC) Init(w *eventline.Worker)

+ func (jegc *JobExecutionGC) ProcessJob() (bool, error)

+ func (jegc *JobExecutionGC) Start() error

+ func (jegc *JobExecutionGC) Stop()

+ type JobExecutionWatcher struct

+ Log *dlog.Logger

+ Service *Service

+ func NewJobExecutionWatcher(s *Service) *JobExecutionWatcher

+ func (w *JobExecutionWatcher) Init(worker *eventline.Worker)

+ func (w *JobExecutionWatcher) ProcessJob() (bool, error)

+ func (w *JobExecutionWatcher) Start() error

+ func (w *JobExecutionWatcher) Stop()

type NotificationsCfg

+ AllowedDomains []string

+ type ProService interface

+ DefaultServiceCfg func() check.Object

+ Init func(*Service) error

+ Start func() error

+ Stop func()

+ Terminate func()

type Service

+ func (s *Service) DefaultServiceCfg() interface{}

+ func (s *Service) UpdateJobExecutionFailure(conn pg.Conn, je *eventline.JobExecution, format string, args ...interface{}) error

+ func (s *Service) ValidateServiceCfg() error

type ServiceCfg

+ AllowedRunners []string

+ DaemonAPI *daemon.APICfg

+ JobExecutionRefreshInterval int

+ JobExecutionRetention int

+ JobExecutionTimeout int

+ MaxParallelJobExecutions int

+ ProCfg check.Object

+ SessionRetention int

+ func (cfg *ServiceCfg) Check(c *check.Checker, s *Service)

type ServiceData

+ ProService ProService

+ type SessionGC struct

+ Log *dlog.Logger

+ Service *Service

+ func NewSessionGC(s *Service) *SessionGC

+ func (sgc *SessionGC) Init(w *eventline.Worker)

+ func (sgc *SessionGC) ProcessJob() (bool, error)

+ func (sgc *SessionGC) Start() error

+ func (sgc *SessionGC) Stop()

v0

v0.9.1

Jul 29, 2022

v0.9.0

Jul 19, 2022

Changes in this version

+ const PgAdvisoryLockId1

+ const PgAdvisoryLockId2JobScheduling

+ const PgAdvisoryLockId2ServiceInit

+ const SessionCookieName

+ const SessionTTL

+ var Connectors = []eventline.Connector

+ var ErrAdminRoleRequired = errors.New("admin role required")

+ var ErrAuthenticationRequired = errors.New("authentication required")

+ var ErrIdentityNotRefreshable = errors.New("identity is not refreshable")

+ var ErrInvalidProjectId = errors.New("invalid project id")

+ var ErrInvalidSessionCookie = errors.New("invalid session cookie")

+ var ErrMissingProjectId = errors.New("missing project id")

+ var ErrUnknownAPIKey = errors.New("unknown api key")

+ var ErrUnknownAccount = errors.New("unknown account")

+ var ErrUnknownSession = errors.New("unknown session")

+ var ErrWrongPassword = errors.New("wrong password")

+ var Runners = []*eventline.RunnerDef

+ func DecodeOAuth2State(state string) (eventline.Id, eventline.Id, error)

+ func DefaultProjectNotificationSettings(project *eventline.Project) *eventline.ProjectNotificationSettings

+ func DefaultProjectSettings(project *eventline.Project) *eventline.ProjectSettings

+ func EncodeOAuth2State(identityId eventline.Id, sessionId eventline.Id) (string, error)

+ func IdentityConnectorSelect(name string) *web.Select

+ func IdentityTypeSelect(cdef *eventline.ConnectorDef, name string) *web.Select

+ func NewLoginMenu(selectedEntry string) *web.Menu

+ func NewMainMenu(selectedEntry string) *web.Menu

+ type APIHTTPServer struct

+ func NewAPIHTTPServer(service *Service) (*APIHTTPServer, error)

+ type DuplicateAPIKeyNameError struct

+ Name string

+ func (err DuplicateAPIKeyNameError) Error() string

+ type DuplicateIdentityNameError struct

+ Name string

+ func (err DuplicateIdentityNameError) Error() string

+ type DuplicateProjectNameError struct

+ Name string

+ func (err DuplicateProjectNameError) Error() string

+ type DuplicateUsernameError struct

+ Username string

+ func (err DuplicateUsernameError) Error() string

+ type EventWorker struct

+ Log *log.Logger

+ Service *Service

+ func NewEventWorker(s *Service) *EventWorker

+ func (ew *EventWorker) Init(w *eventline.Worker)

+ func (ew *EventWorker) ProcessJob() (bool, error)

+ func (ew *EventWorker) Start() error

+ func (ew *EventWorker) Stop()

+ type HTTPContext struct

+ AccountId *eventline.Id

+ AccountRole *eventline.AccountRole

+ AccountSettings *eventline.AccountSettings

+ ProjectId *eventline.Id

+ ProjectIdChecked bool

+ ProjectName string

+ Session *eventline.Session

+ func (ctx *HTTPContext) AccountProjectScope() eventline.Scope

+ func (ctx *HTTPContext) AccountScope() eventline.Scope

+ func (ctx *HTTPContext) ProjectScope() eventline.Scope

+ type HTTPHandler struct

+ Context *HTTPContext

+ Interface HTTPInterface

+ RouteOptions HTTPRouteOptions

+ Service *Service

+ func (h *HTTPHandler) DeleteCookie()

+ func (h *HTTPHandler) IdRouteVariable(name string) (id eventline.Id, err error)

+ func (h *HTTPHandler) LoadSession(sessionId eventline.Id) error

+ func (h *HTTPHandler) ParseCursor(sorts eventline.Sorts) (*eventline.Cursor, error)

+ func (h *HTTPHandler) ParseMetricParameters() (*eventline.MetricParameters, error)

+ func (h *HTTPHandler) RedirectionTarget() string

+ func (h *HTTPHandler) ReplyAuthError(status int, code string, format string, args ...interface{})

+ func (h *HTTPHandler) ReplyContent(status int, content web.Content)

+ func (h *HTTPHandler) ReplyJSONLocation(status int, uri string, extra map[string]interface{})

+ func (h *HTTPHandler) ReplyView(status int, view *web.View)

+ func (h *HTTPHandler) SetContextSession(session *eventline.Session)

+ func (h *HTTPHandler) SetSessionCookie(cookie *http.Cookie)

+ func (h *HTTPHandler) TimestampQueryParameter(name string) (*time.Time, error)

+ type HTTPInterface string

+ const APIHTTPInterface

+ const WebHTTPInterface

+ type HTTPRouteFunc func(*HTTPHandler)

+ type HTTPRouteOptions struct

+ Admin bool

+ Project bool

+ Public bool

+ type HTTPServer struct

+ Log *log.Logger

+ Pg *pg.Client

+ Server *dhttp.Server

+ Service *Service

+ func (s *HTTPServer) CreateProject(h *HTTPHandler, newProject *eventline.NewProject) (*eventline.Project, error)

+ func (s *HTTPServer) DeleteJob(h *HTTPHandler, jobId eventline.Id) error

+ func (s *HTTPServer) DeleteProject(h *HTTPHandler, projectId eventline.Id) error

+ func (s *HTTPServer) DisableJob(h *HTTPHandler, jobId eventline.Id) error

+ func (s *HTTPServer) EnableJob(h *HTTPHandler, jobId eventline.Id) error

+ func (s *HTTPServer) ExecuteJob(h *HTTPHandler, jobId eventline.Id, input *eventline.JobExecutionInput) (*eventline.JobExecution, error)

+ func (s *HTTPServer) LoadAccount(h *HTTPHandler) (*eventline.Account, error)

+ func (s *HTTPServer) LoadAccountPage(h *HTTPHandler) (*eventline.Page, error)

+ func (s *HTTPServer) LoadIdentity(h *HTTPHandler, identityId eventline.Id) (*eventline.Identity, error)

+ func (s *HTTPServer) LoadJob(h *HTTPHandler, jobId eventline.Id) (*eventline.Job, error)

+ func (s *HTTPServer) LoadJobByName(h *HTTPHandler, jobName string) (*eventline.Job, error)

+ func (s *HTTPServer) LoadProject(h *HTTPHandler, projectId eventline.Id) (*eventline.Project, error)

+ func (s *HTTPServer) LoadProjectByName(h *HTTPHandler, projectName string) (*eventline.Project, error)

+ func (s *HTTPServer) LoadProjectPage(h *HTTPHandler) (*eventline.Page, error)

+ func (s *HTTPServer) LogIn(h *HTTPHandler, loginData *LoginData) (*eventline.Session, error)

+ func (s *HTTPServer) UpdateProject(h *HTTPHandler, projectId eventline.Id, newProject *eventline.NewProject) (*eventline.Project, error)

+ type IdentityInUseError struct

+ Id eventline.Id

+ func (err IdentityInUseError) Error() string

+ type IdentityRefresher struct

+ Log *log.Logger

+ Service *Service

+ func NewIdentityRefresher(s *Service) *IdentityRefresher

+ func (ir *IdentityRefresher) Init(w *eventline.Worker)

+ func (ir *IdentityRefresher) ProcessJob() (bool, error)

+ func (ir *IdentityRefresher) Start() error

+ func (ir *IdentityRefresher) Stop()

+ type JobScheduler struct

+ Log *log.Logger

+ Service *Service

+ func NewJobScheduler(s *Service) *JobScheduler

+ func (js *JobScheduler) Init(w *eventline.Worker)

+ func (js *JobScheduler) ProcessJob() (bool, error)

+ func (js *JobScheduler) Start() error

+ func (js *JobScheduler) Stop()

+ type JobSpecChecker struct

+ Checker *check.Checker

+ Conn pg.Conn

+ Identities map[string]*eventline.Identity

+ JobSpec *eventline.JobSpec

+ Scope eventline.Scope

+ Service *Service

+ type LoginData struct

+ Password string

+ Username string

+ func (data *LoginData) Check(c *check.Checker)

+ type NotificationWorker struct

+ Log *log.Logger

+ Service *Service

+ func NewNotificationWorker(s *Service) *NotificationWorker

+ func (nw *NotificationWorker) Init(w *eventline.Worker)

+ func (nw *NotificationWorker) ProcessJob() (bool, error)

+ func (nw *NotificationWorker) Start() error

+ func (nw *NotificationWorker) Stop()

+ type NotificationsCfg struct

+ FromAddress string

+ SMTPServer *SMTPServerCfg

+ Signature string

+ SubjectPrefix string

+ func DefaultNotificationsCfg() *NotificationsCfg

+ func (cfg *NotificationsCfg) Check(c *check.Checker)

+ type ProjectConfiguration struct

+ Project *eventline.NewProject

+ ProjectNotificationSettings *eventline.ProjectNotificationSettings

+ ProjectSettings *eventline.ProjectSettings

+ func (cfg *ProjectConfiguration) Check(c *check.Checker)

+ type Runner interface

+ Start func() error

+ type SMTPServerCfg struct

+ Address string

+ Password string

+ Username string

+ func (cfg *SMTPServerCfg) Check(c *check.Checker)

+ type Service struct

+ APIHTTPServer *APIHTTPServer

+ BuildIdHash string

+ Cfg ServiceCfg

+ Daemon *daemon.Daemon

+ Data ServiceData

+ Log *log.Logger

+ TextTemplate *template.Template

+ WebHTTPServer *WebHTTPServer

+ WebHTTPServerURI *url.URL

+ func NewService(data ServiceData) *Service

+ func (s *Service) AbortJobExecution(jeId eventline.Id, scope eventline.Scope) (*eventline.JobExecution, error)

+ func (s *Service) AddFavouriteJob(conn pg.Conn, jobId eventline.Id, scope eventline.Scope) error

+ func (s *Service) ComposeNotificationMessage(recipients []string, subject, templateName string, templateData interface{}) ([]byte, error)

+ func (s *Service) CreateAPIKey(newAPIKey *eventline.NewAPIKey, scope eventline.Scope) (*eventline.APIKey, string, error)

+ func (s *Service) CreateAccount(newAccount *eventline.NewAccount) (*eventline.Account, error)

+ func (s *Service) CreateIdentity(newIdentity *eventline.NewIdentity, scope eventline.Scope) (*eventline.Identity, error)

+ func (s *Service) CreateNotification(conn pg.Conn, recipients []string, subject, templateName string, ...) error

+ func (s *Service) CreateOrUpdateJob(conn pg.Conn, spec *eventline.JobSpec, scope eventline.Scope) (*eventline.Job, bool, error)

+ func (s *Service) CreateProject(newProject *eventline.NewProject, accountId *eventline.Id) (*eventline.Project, error)

+ func (s *Service) CreateSession(conn pg.Conn, ns *eventline.NewSession, scope eventline.Scope) (*eventline.Session, error)

+ func (s *Service) CreateSubscription(conn pg.Conn, job *eventline.Job, scope eventline.Scope) (*eventline.Subscription, error)

+ func (s *Service) DaemonCfg() (daemon.DaemonCfg, error)

+ func (s *Service) DeleteAPIKey(keyId eventline.Id, scope eventline.Scope) error

+ func (s *Service) DeleteAccount(accountId eventline.Id) error

+ func (s *Service) DeleteIdentities(conn pg.Conn, scope eventline.Scope) error

+ func (s *Service) DeleteIdentity(identityId eventline.Id, scope eventline.Scope) error

+ func (s *Service) DeleteJob(conn pg.Conn, job *eventline.Job, scope eventline.Scope) error

+ func (s *Service) DeleteProject(projectId eventline.Id, hctx *HTTPContext) error

+ func (s *Service) DeliverNotification(conn pg.Conn, n *eventline.Notification) error

+ func (s *Service) DisableJob(conn pg.Conn, jobId eventline.Id, scope eventline.Scope) (*eventline.Job, error)

+ func (s *Service) EnableJob(conn pg.Conn, jobId eventline.Id, scope eventline.Scope) (*eventline.Job, error)

+ func (s *Service) ExecuteJob(conn pg.Conn, jobId eventline.Id, input *eventline.JobExecutionInput, ...) (*eventline.JobExecution, error)

+ func (s *Service) FindConnectorWorker(cname string) *eventline.Worker

+ func (s *Service) FindWorker(name string) *eventline.Worker

+ func (s *Service) IdentityRedirectionURI(identity *eventline.Identity, sessionId eventline.Id, defaultURI string) (string, error)

+ func (s *Service) Init(d *daemon.Daemon) error

+ func (s *Service) InstantiateJob(conn pg.Conn, job *eventline.Job, event *eventline.Event, ...) (*eventline.JobExecution, error)

+ func (s *Service) LoadJobExecutionContext(conn pg.Conn, je *eventline.JobExecution) (*eventline.ExecutionContext, error)

+ func (s *Service) LogIn(data *LoginData, httpCtx *HTTPContext) (*eventline.Session, error)

+ func (s *Service) LogOut(httpCtx *HTTPContext) error

+ func (s *Service) MaybeCreateDefaultAccount(conn pg.Conn) (*eventline.Account, error)

+ func (s *Service) MaybeCreateDefaultProject(conn pg.Conn, account *eventline.Account) (*eventline.Project, error)

+ func (s *Service) ProcessEvent(conn pg.Conn, event *eventline.Event, scope eventline.Scope) (bool, error)

+ func (s *Service) ProcessSubscription(conn pg.Conn, sctx *eventline.SubscriptionContext) error

+ func (s *Service) RefreshIdentity(identityId eventline.Id, scope eventline.Scope) error

+ func (s *Service) RemoveFavouriteJob(conn pg.Conn, jobId eventline.Id, scope eventline.Scope) error

+ func (s *Service) RenderNotificationText(name string, data interface{}) ([]byte, error)

+ func (s *Service) ReplayEvent(eventId eventline.Id, scope eventline.Scope) (*eventline.Event, error)

+ func (s *Service) RestartJobExecution(jeId eventline.Id, scope eventline.Scope) (*eventline.JobExecution, error)

+ func (s *Service) SelectAccountProject(projectId eventline.Id, hctx *HTTPContext) error

+ func (s *Service) SelfUpdateAccount(accountId eventline.Id, update *eventline.AccountSelfUpdate, hctx *HTTPContext) error

+ func (s *Service) SelfUpdateAccountPassword(accountId eventline.Id, update *eventline.AccountPasswordUpdate) error

+ func (s *Service) SendJobExecutionNotification(conn pg.Conn, je *eventline.JobExecution) error

+ func (s *Service) ServiceCfg() interface{}

+ func (s *Service) Start(d *daemon.Daemon) error

+ func (s *Service) StartJobExecution(conn pg.Conn, je *eventline.JobExecution, scope eventline.Scope) error

+ func (s *Service) StartRunner(data *eventline.RunnerData) (Runner, error)

+ func (s *Service) Stop(d *daemon.Daemon)

+ func (s *Service) Terminate(d *daemon.Daemon)

+ func (s *Service) TerminateSubscription(conn pg.Conn, subscription *eventline.Subscription, projectDeletion bool, ...) error

+ func (s *Service) TerminateSubscriptions(conn pg.Conn, scope eventline.Scope) error

+ func (s *Service) UpdateAccount(accountId eventline.Id, update *eventline.AccountUpdate) (*eventline.Account, error)

+ func (s *Service) UpdateAccountPassword(accountId eventline.Id, update *eventline.AccountPasswordUpdate) (*eventline.Account, error)

+ func (s *Service) UpdateIdentity(identityId eventline.Id, newIdentity *eventline.NewIdentity, ...) (*eventline.Identity, error)

+ func (s *Service) UpdateProjectConfiguration(projectId eventline.Id, cfg *ProjectConfiguration) error

+ func (s *Service) ValidateJobSpec(conn pg.Conn, spec *eventline.JobSpec, scope eventline.Scope) error

+ func (s *Service) WrapRoute(fn HTTPRouteFunc, options HTTPRouteOptions, iface HTTPInterface) dhttp.RouteFunc

+ type ServiceCfg struct

+ APIHTTPServer dhttp.ServerCfg

+ Connectors map[string]json.RawMessage

+ DataDirectory string

+ EncryptionKey dcrypto.AES256Key

+ Influx *influx.ClientCfg

+ JobRetention int

+ Logger *log.LoggerCfg

+ MaxParallelJobs int

+ Notifications *NotificationsCfg

+ Pg *pg.ClientCfg

+ Runners map[string]json.RawMessage

+ WebHTTPServer dhttp.ServerCfg

+ WebHTTPServerURI string

+ Workers map[string]eventline.WorkerCfg

+ func DefaultServiceCfg() ServiceCfg

+ type ServiceData struct

+ BuildId string

+ Connectors []eventline.Connector

+ Product string

+ Runners []*eventline.RunnerDef

+ type SubscriptionWorker struct

+ Log *log.Logger

+ Service *Service

+ func NewSubscriptionWorker(s *Service) *SubscriptionWorker

+ func (sw *SubscriptionWorker) Init(w *eventline.Worker)

+ func (sw *SubscriptionWorker) ProcessJob() (bool, error)

+ func (sw *SubscriptionWorker) Start() error

+ func (sw *SubscriptionWorker) Stop()

+ type WebContext struct

+ AccountSettings *eventline.AccountSettings

+ LoggedIn bool

+ Product string

+ ProjectId *eventline.Id

+ ProjectIdChecked bool

+ ProjectName string

+ PublicPage bool

+ Version string

+ VersionHash string

+ func (ctx *WebContext) FormatAltDate(t time.Time) (s string)

+ func (ctx *WebContext) FormatDate(t time.Time) (s string)

+ func (ctx *WebContext) FormatDuration(d time.Duration) (s string)

+ type WebHTTPServer struct

+ HTMLTemplate *template.Template

+ func NewWebHTTPServer(service *Service) (*WebHTTPServer, error)

+ func (s *WebHTTPServer) NewTemplate(name string, data interface{}) *web.Template

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