event

Documentation

Index

• type Emitter
  • func NewEmitter(brokers []string, topic, source string) (*Emitter, error)
  • func (e *Emitter) InstanceCreated(ctx context.Context, instance *instancev1.Instance) error
  • func (e *Emitter) InstanceEnded(ctx context.Context, instance *instancev1.Instance) error
  • func (e *Emitter) InstanceStateChanged(ctx context.Context, instance *instancev1.Instance, old json.RawMessage, ...) error

Types

type Emitter

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

func NewEmitter

func NewEmitter(brokers []string, topic, source string) (*Emitter, error)

NewEmitter creates an new Emitter that emitts events in the cloud event Kafka format to the configured Kafka brokers

func (*Emitter) InstanceCreated

func (e *Emitter) InstanceCreated(ctx context.Context, instance *instancev1.Instance) error

InstanceCreated emitts an InstanceCreatedEvent

func (*Emitter) InstanceEnded

func (e *Emitter) InstanceEnded(ctx context.Context, instance *instancev1.Instance) error

InstanceEnded emitts an InstanceEndedEvent

func (*Emitter) InstanceStateChanged

func (e *Emitter) InstanceStateChanged(
	ctx context.Context,
	instance *instancev1.Instance,
	old json.RawMessage,
	new json.RawMessage,
) error

InstanceStateChanged emitts an InstanceStateChangedEvent