Documentation ¶
Index ¶
- Variables
- func NewEIAuthorizer(db *sql.DB, ei bridges.ExternalInitiator) *eiAuthorizer
- func NewExternalInitiatorManager(db *sqlx.DB, httpclient HTTPClient, lggr logger.Logger, cfg pg.QConfig) *externalInitiatorManager
- func ValidatedWebhookSpec(tomlString string, externalInitiatorManager ExternalInitiatorManager) (jb job.Job, err error)
- type Authorizer
- type AuthorizerConfig
- type Delegate
- func (d *Delegate) AfterJobCreated(jb job.Job)
- func (d *Delegate) BeforeJobCreated(spec job.Job)
- func (d *Delegate) BeforeJobDeleted(jb job.Job)
- func (d *Delegate) JobType() job.Type
- func (d *Delegate) ServicesForSpec(spec job.Job) ([]job.ServiceCtx, error)
- func (d *Delegate) WebhookJobRunner() JobRunner
- type ExternalInitiatorManager
- type HTTPClient
- type JobRunner
- type JobSpecNotice
- type NullExternalInitiatorManager
- type TOMLWebhookSpec
- type TOMLWebhookSpecExternalInitiator
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrJobNotExists = errors.New("job does not exist")
Functions ¶
func NewEIAuthorizer ¶ added in v0.10.11
func NewEIAuthorizer(db *sql.DB, ei bridges.ExternalInitiator) *eiAuthorizer
func NewExternalInitiatorManager ¶
func NewExternalInitiatorManager(db *sqlx.DB, httpclient HTTPClient, lggr logger.Logger, cfg pg.QConfig) *externalInitiatorManager
NewExternalInitiatorManager returns the concrete externalInitiatorManager
func ValidatedWebhookSpec ¶
func ValidatedWebhookSpec(tomlString string, externalInitiatorManager ExternalInitiatorManager) (jb job.Job, err error)
Types ¶
type Authorizer ¶ added in v0.10.11
type Authorizer interface {
CanRun(ctx context.Context, config AuthorizerConfig, jobUUID uuid.UUID) (bool, error)
}
func NewAuthorizer ¶ added in v0.10.11
func NewAuthorizer(db *sql.DB, user *sessions.User, ei *bridges.ExternalInitiator) Authorizer
type AuthorizerConfig ¶ added in v0.10.11
type AuthorizerConfig interface {
FeatureExternalInitiators() bool
}
type Delegate ¶
type Delegate struct {
// contains filtered or unexported fields
}
func NewDelegate ¶
func (*Delegate) AfterJobCreated ¶ added in v0.10.11
func (*Delegate) BeforeJobCreated ¶ added in v1.11.0
func (*Delegate) BeforeJobDeleted ¶ added in v0.10.11
func (*Delegate) ServicesForSpec ¶
ServicesForSpec satisfies the job.Delegate interface.
func (*Delegate) WebhookJobRunner ¶
type ExternalInitiatorManager ¶
type ExternalInitiatorManager interface { Notify(webhookSpecID int32) error DeleteJob(webhookSpecID int32) error FindExternalInitiatorByName(name string) (bridges.ExternalInitiator, error) }
ExternalInitiatorManager manages HTTP requests to remote external initiators
type HTTPClient ¶ added in v0.10.11
type JobSpecNotice ¶
type JobSpecNotice struct { JobID uuid.UUID `json:"jobId"` Type string `json:"type"` Params models.JSON `json:"params,omitempty"` }
JobSpecNotice is sent to the External Initiator when JobSpecs are created.
type NullExternalInitiatorManager ¶
type NullExternalInitiatorManager struct{}
func (NullExternalInitiatorManager) DeleteJob ¶
func (NullExternalInitiatorManager) DeleteJob(int32) error
func (NullExternalInitiatorManager) FindExternalInitiatorByName ¶
func (NullExternalInitiatorManager) FindExternalInitiatorByName(name string) (bridges.ExternalInitiator, error)
func (NullExternalInitiatorManager) Notify ¶
func (NullExternalInitiatorManager) Notify(int32) error
type TOMLWebhookSpec ¶ added in v0.10.11
type TOMLWebhookSpec struct {
ExternalInitiators []TOMLWebhookSpecExternalInitiator `toml:"externalInitiators"`
}
type TOMLWebhookSpecExternalInitiator ¶ added in v0.10.11
Source Files ¶
Click to show internal directories.
Click to hide internal directories.