event_v2

Documentation

Index

• Constants
• func Dequeue(ctx context.Context, db *gorp.DbMap, store cache.Store, ...)
• func PublishAnalysisDone(ctx context.Context, store cache.Store, vcsName, repoName string, ...)
• func PublishAnalysisStart(ctx context.Context, store cache.Store, vcsName, repoName string, ...)
• func PublishEntityEvent(ctx context.Context, store cache.Store, eventType string, ...)
• func PublishHatcheryEvent(ctx context.Context, store cache.Store, eventType string, h sdk.Hatchery, ...)
• func PublishIntegrationModelEvent(ctx context.Context, store cache.Store, eventType string, ...)
• func PublishOrganizationEvent(ctx context.Context, store cache.Store, eventType string, org sdk.Organization, ...)
• func PublishPermissionEvent(ctx context.Context, store cache.Store, eventType string, perm sdk.RBAC, ...)
• func PublishPluginEvent(ctx context.Context, store cache.Store, typeEvent string, p sdk.GRPCPlugin, ...)
• func PublishProjectEvent(ctx context.Context, store cache.Store, eventType string, p sdk.Project, ...)
• func PublishProjectIntegrationEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, ...)
• func PublishProjectNotificationEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, ...)
• func PublishProjectVariableSetEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, ...)
• func PublishProjectVariableSetItemEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, ...)
• func PublishRegionEvent(ctx context.Context, store cache.Store, typeEvent string, reg sdk.Region, ...)
• func PublishRepositoryEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, ...)
• func PublishRunEvent(ctx context.Context, store cache.Store, eventType string, wr sdk.V2WorkflowRun, ...)
• func PublishRunJobEvent(ctx context.Context, store cache.Store, eventType, vcsName, repoName string, ...)
• func PublishRunJobManualEvent(ctx context.Context, store cache.Store, eventType string, wr sdk.V2WorkflowRun, ...)
• func PublishRunJobRunResult(ctx context.Context, store cache.Store, eventType, vcsName, repoName string, ...)
• func PublishUserEvent(ctx context.Context, store cache.Store, typeEvent string, ...)
• func PublishUserGPGEvent(ctx context.Context, store cache.Store, typeEvent string, g sdk.UserGPGKey, ...)
• func PublishVCSEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, ...)

Constants

const (
	EventUIWS       = "event:ui"
	EventHatcheryWS = "event:run:job"
)

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 PublishAnalysisDone

func PublishAnalysisDone(ctx context.Context, store cache.Store, vcsName, repoName string, a *sdk.ProjectRepositoryAnalysis, u sdk.AuthentifiedUser)

func PublishAnalysisStart

func PublishAnalysisStart(ctx context.Context, store cache.Store, vcsName, repoName string, a *sdk.ProjectRepositoryAnalysis)

func PublishEntityEvent

func PublishEntityEvent(ctx context.Context, store cache.Store, eventType string, vcsName, repoName string, ent sdk.Entity, u *sdk.AuthentifiedUser)

func PublishHatcheryEvent

func PublishHatcheryEvent(ctx context.Context, store cache.Store, eventType string, h sdk.Hatchery, u *sdk.AuthentifiedUser)

func PublishIntegrationModelEvent

func PublishIntegrationModelEvent(ctx context.Context, store cache.Store, eventType string, m sdk.IntegrationModel, u sdk.AuthentifiedUser)

func PublishOrganizationEvent

func PublishOrganizationEvent(ctx context.Context, store cache.Store, eventType string, org sdk.Organization, u sdk.AuthentifiedUser)

func PublishPermissionEvent

func PublishPermissionEvent(ctx context.Context, store cache.Store, eventType string, perm sdk.RBAC, u sdk.AuthentifiedUser)

func PublishPluginEvent

func PublishPluginEvent(ctx context.Context, store cache.Store, typeEvent string, p sdk.GRPCPlugin, u sdk.AuthentifiedUser)

func PublishProjectEvent

func PublishProjectEvent(ctx context.Context, store cache.Store, eventType string, p sdk.Project, u sdk.AuthentifiedUser)

func PublishProjectIntegrationEvent

func PublishProjectIntegrationEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, i sdk.ProjectIntegration, u sdk.AuthentifiedUser)

func PublishProjectNotificationEvent

func PublishProjectNotificationEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, notif sdk.ProjectNotification, u sdk.AuthentifiedUser)

func PublishProjectVariableSetEvent

func PublishProjectVariableSetEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, vs sdk.ProjectVariableSet, u sdk.AuthentifiedUser)

func PublishProjectVariableSetItemEvent

func PublishProjectVariableSetItemEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, vsName string, item sdk.ProjectVariableSetItem, u sdk.AuthentifiedUser)

func PublishRegionEvent

func PublishRegionEvent(ctx context.Context, store cache.Store, typeEvent string, reg sdk.Region, u sdk.AuthentifiedUser)

func PublishRepositoryEvent

func PublishRepositoryEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, vcsName string, repo sdk.ProjectRepository, u sdk.AuthentifiedUser)

func PublishRunEvent

func PublishRunEvent(ctx context.Context, store cache.Store, eventType string, wr sdk.V2WorkflowRun, u sdk.AuthentifiedUser)

func PublishRunJobEvent

func PublishRunJobEvent(ctx context.Context, store cache.Store, eventType, vcsName, repoName string, rj sdk.V2WorkflowRunJob)

func PublishRunJobManualEvent

func PublishRunJobManualEvent(ctx context.Context, store cache.Store, eventType string, wr sdk.V2WorkflowRun, jobID string, gateInputs map[string]interface{}, u sdk.AuthentifiedUser)

func PublishRunJobRunResult

func PublishRunJobRunResult(ctx context.Context, store cache.Store, eventType, vcsName, repoName string, rj sdk.V2WorkflowRunJob, rr sdk.V2WorkflowRunResult)

func PublishUserEvent

func PublishUserEvent(ctx context.Context, store cache.Store, typeEvent string, u sdk.AuthentifiedUser)

func PublishUserGPGEvent

func PublishUserGPGEvent(ctx context.Context, store cache.Store, typeEvent string, g sdk.UserGPGKey, u sdk.AuthentifiedUser)

func PublishVCSEvent

func PublishVCSEvent(ctx context.Context, store cache.Store, eventType string, projectKey string, vcs sdk.VCSProject, u sdk.AuthentifiedUser)