Documentation
¶
Index ¶
- Constants
- func Dequeue(ctx context.Context, db *gorp.DbMap, store cache.Store, ...)
- func NewEventJobSummaryV2(wr sdk.V2WorkflowRun, jobrun sdk.V2WorkflowRunJob) sdk.EventJobSummary
- func PublishAnalysisDone(ctx context.Context, store cache.Store, vcsName, repoName string, ...)
- func PublishAnalysisStart(ctx context.Context, store cache.Store, vcsName, repoName string, ...)
- func PublishConcurrencyEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishEntityEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishHatcheryEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishIntegrationModelEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishOrganizationEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishPermissionEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, perm sdk.RBAC, ...)
- func PublishPluginEvent(ctx context.Context, store cache.Store, typeEvent sdk.EventType, ...)
- func PublishProjectEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, p sdk.Project, ...)
- func PublishProjectIntegrationEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishProjectNotificationEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishProjectPurgeEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishProjectVariableSetEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishProjectVariableSetItemEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishRegionEvent(ctx context.Context, store cache.Store, typeEvent sdk.EventType, ...)
- func PublishRepositoryEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishRunEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishRunJobEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishRunJobManualEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishRunJobRunResult(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
- func PublishUserEvent(ctx context.Context, store cache.Store, typeEvent sdk.EventType, ...)
- func PublishUserGPGEvent(ctx context.Context, store cache.Store, typeEvent sdk.EventType, ...)
- func PublishVCSEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, ...)
Constants ¶
View Source
const ( EventUIWS = "event:ui" EventHatcheryWS = "event:run:job" )
Variables ¶
This section is empty.
Functions ¶
func Dequeue ¶
func Dequeue(ctx context.Context, db *gorp.DbMap, store cache.Store, goroutines *sdk.GoRoutines, cdsUIURL string)
Dequeue runs in a goroutine and dequeue event from cache
func NewEventJobSummaryV2 ¶ added in v0.55.0
func NewEventJobSummaryV2(wr sdk.V2WorkflowRun, jobrun sdk.V2WorkflowRunJob) sdk.EventJobSummary
func PublishAnalysisDone ¶
func PublishAnalysisDone(ctx context.Context, store cache.Store, vcsName, repoName string, a *sdk.ProjectRepositoryAnalysis, u *sdk.V2Initiator)
func PublishAnalysisStart ¶
func PublishConcurrencyEvent ¶ added in v0.55.2
func PublishEntityEvent ¶
func PublishHatcheryEvent ¶
func PublishIntegrationModelEvent ¶
func PublishIntegrationModelEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, m sdk.IntegrationModel, u sdk.AuthentifiedUser)
func PublishOrganizationEvent ¶
func PublishOrganizationEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, org sdk.Organization, u sdk.AuthentifiedUser)
func PublishPermissionEvent ¶
func PublishPluginEvent ¶
func PublishPluginEvent(ctx context.Context, store cache.Store, typeEvent sdk.EventType, p sdk.GRPCPlugin, u sdk.AuthentifiedUser)
func PublishProjectEvent ¶
func PublishProjectPurgeEvent ¶ added in v0.56.0
func PublishRegionEvent ¶
func PublishRepositoryEvent ¶
func PublishRunEvent ¶
func PublishRunEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, wr sdk.V2WorkflowRun, jobs map[string]sdk.V2WorkflowRunJob, runResults []sdk.V2WorkflowRunResult, initiator *sdk.V2Initiator)
func PublishRunJobEvent ¶
func PublishRunJobEvent(ctx context.Context, store cache.Store, eventType sdk.EventType, wr sdk.V2WorkflowRun, rj sdk.V2WorkflowRunJob)
func PublishRunJobRunResult ¶
func PublishUserEvent ¶
func PublishUserGPGEvent ¶
func PublishUserGPGEvent(ctx context.Context, store cache.Store, typeEvent sdk.EventType, g sdk.UserGPGKey, u sdk.AuthentifiedUser)
func PublishVCSEvent ¶
Types ¶
This section is empty.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.