source

Documentation

Index

• Constants
• type Source

Constants

const (

	// ReceiveSuccessMetricName of a counter to be incremented on every successful receive.
	ReceiveSuccessMetricName = "machine_source_receive_success"

	// ReceiveFailureMetricName of a counter to be incremented on every failed receive.
	ReceiveFailureMetricName = "machine_source_receive_failure"
)

Types

type Source

type Source interface {
	// Start the process of receiving events.
	Start(ctx context.Context) (<-chan machine.Event, error)
}

Source provides a channel of machine.Events as sent from machines.

Note that machines should only send updates if state or dimensions has actually changed.