argoevents

Documentation

Index

• Constants
• func GetURLFromCluster(cluster nautescrd.Cluster, hostCluster *nautescrd.Cluster, isSecret bool) (string, error)
• func NewSyncer(client client.Client) interfaces.EventBus
• type Syncer
  • func (s Syncer) RemoveEvents(ctx context.Context, task interfaces.RuntimeSyncTask) error
  • func (s Syncer) SyncEvents(ctx context.Context, task interfaces.RuntimeSyncTask) (*interfaces.EventBusDeploymentResult, error)

Constants

const (
	IsolationShared    = "shared"
	IsolationExclusive = "exclusive"

	ConfigMapTriggerTemplateName = "nautes-runtime-trigger-templates"
)

Functions

func GetURLFromCluster

func GetURLFromCluster(cluster nautescrd.Cluster, hostCluster *nautescrd.Cluster, isSecret bool) (string, error)

func NewSyncer

func NewSyncer(client client.Client) interfaces.EventBus

Types

type Syncer

type Syncer struct {
	// contains filtered or unexported fields
}

func (Syncer) RemoveEvents

func (s Syncer) RemoveEvents(ctx context.Context, task interfaces.RuntimeSyncTask) error

RemoveEvents make sure that event bus defined in project pipeline runtime is not existed any more.

func (Syncer) SyncEvents

func (s Syncer) SyncEvents(ctx context.Context, task interfaces.RuntimeSyncTask) (*interfaces.EventBusDeploymentResult, error)

SyncEvents used to make sure event bus is the same as project runtime define in dest cluster. It will create argo eventsource and sensor.