Documentation
¶
Overview ¶
Package handler deals with appropriately reacting to all ACS messages as well as maintaining the connection to ACS.
Index ¶
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.