event

Documentation

Overview

Package handler deals with appropriately reacting to all ACS messages as well as maintaining the connection to ACS.

Index

• type ACSDeregisterInstanceStream
  • func NewACSDeregisterInstanceStream() *ACSDeregisterInstanceStream
  • func (events *ACSDeregisterInstanceStream) EventChannel() chan struct{}
  • func (events *ACSDeregisterInstanceStream) StartListening(ctx context.Context)
  • func (events *ACSDeregisterInstanceStream) Subscribe(handler eventHandler)
  • func (events *ACSDeregisterInstanceStream) Unsubscribe(handlerToUnsubscribe eventHandler)

Types

type ACSDeregisterInstanceStream

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

ACSDeregisterInstanceStream is the event stream for deregistering container instance event that was received from ACS.

func NewACSDeregisterInstanceStream

func NewACSDeregisterInstanceStream() *ACSDeregisterInstanceStream

func (*ACSDeregisterInstanceStream) EventChannel

func (events *ACSDeregisterInstanceStream) EventChannel() chan struct{}

EventChannel returns the channel the event stream is listening

func (*ACSDeregisterInstanceStream) StartListening

func (events *ACSDeregisterInstanceStream) StartListening(ctx context.Context)

StartListening start listening to the event stream and handle received event

func (*ACSDeregisterInstanceStream) Subscribe

func (events *ACSDeregisterInstanceStream) Subscribe(handler eventHandler)

Subscribe adds the handler to be called into ACSDeregisterInstanceStream

func (*ACSDeregisterInstanceStream) Unsubscribe

func (events *ACSDeregisterInstanceStream) Unsubscribe(handlerToUnsubscribe eventHandler)

Unsubscribe deletes the handler from the ACSDeregisterInstanceStream