events

Documentation

Index

• type DataField
• type DelivererConfig
• type EventDeliverer
  • func NewDeliverer(ctx context.Context, store delivererStore, instanceID string, ...) *EventDeliverer
  • func (d *EventDeliverer) SignalNewEvents(eventType model.EventType)
• type EventProducer
  • func NewProducer(store producerStore, signaler deliverySignaler, env string, ...) *EventProducer
  • func (e *EventProducer) ProduceClusterInstallationStateChangeEvent(clusterInstallation *model.ClusterInstallation, oldState string, ...) error
  • func (e *EventProducer) ProduceClusterStateChangeEvent(cluster *model.Cluster, oldState string, extraDataFields ...DataField) error
  • func (e *EventProducer) ProduceInstallationStateChangeEvent(installation *model.Installation, oldState string, ...) error

Types

type DataField

type DataField struct {
	Key   string
	Value string
}

DataField represents strings key value pair used for events extra data.

type DelivererConfig

type DelivererConfig struct {
	RetryWorkers    int
	UpToDateWorkers int
	MaxBurstWorkers int
}

DelivererConfig is config of EventDeliverer component.

type EventDeliverer

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

EventDeliverer is responsible for delivering events.

func NewDeliverer

func NewDeliverer(ctx context.Context, store delivererStore, instanceID string, log logrus.FieldLogger, cfg DelivererConfig) *EventDeliverer

NewDeliverer creates new EventDeliverer component.

func (*EventDeliverer) SignalNewEvents

func (d *EventDeliverer) SignalNewEvents(eventType model.EventType)

SignalNewEvents attempts to try/retry to send to all subscriptions for particular type of event. It will throttle concurrent deliveries.

type EventProducer

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

EventProducer produces Provisioners' state change events.

func NewProducer

func NewProducer(store producerStore, signaler deliverySignaler, env string, log logrus.FieldLogger) *EventProducer

NewProducer creates new EventProducer.

func (*EventProducer) ProduceClusterInstallationStateChangeEvent

func (e *EventProducer) ProduceClusterInstallationStateChangeEvent(clusterInstallation *model.ClusterInstallation, oldState string, extraDataFields ...DataField) error

ProduceClusterInstallationStateChangeEvent produces state change event for a given ClusterInstallation.

func (*EventProducer) ProduceClusterStateChangeEvent

func (e *EventProducer) ProduceClusterStateChangeEvent(cluster *model.Cluster, oldState string, extraDataFields ...DataField) error

ProduceClusterStateChangeEvent produces state change event for a given Cluster.

func (*EventProducer) ProduceInstallationStateChangeEvent

func (e *EventProducer) ProduceInstallationStateChangeEvent(installation *model.Installation, oldState string, extraDataFields ...DataField) error

ProduceInstallationStateChangeEvent produces state change event for a given Installation.