watcher

Documentation

Index

• type ENIWatcher
  • func New(ctx context.Context, primaryMAC string, state dockerstate.TaskEngineState, ...) (*ENIWatcher, error)
  • func (eniWatcher *ENIWatcher) Init() error
  • func (eniWatcher *ENIWatcher) InjectFields(udevMonitor udevwrapper.Udev)
  • func (eniWatcher *ENIWatcher) Start()
  • func (eniWatcher *ENIWatcher) Stop()

Types

type ENIWatcher

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

ENIWatcher maintains the state of attached ENIs to the instance. It also has supporting elements to maintain consistency and update intervals

func New

func New(ctx context.Context, primaryMAC string,
	state dockerstate.TaskEngineState, stateChangeEvents chan<- statechange.Event) (*ENIWatcher, error)

New is used to return an instance of the ENIWatcher struct

func (*ENIWatcher) Init

func (eniWatcher *ENIWatcher) Init() error

Init initializes a new ENI Watcher

func (*ENIWatcher) InjectFields

func (eniWatcher *ENIWatcher) InjectFields(udevMonitor udevwrapper.Udev)

InjectFields is used to inject mock services.

func (*ENIWatcher) Start

func (eniWatcher *ENIWatcher) Start()

Start periodically updates the state of ENIs connected to the system

func (*ENIWatcher) Stop

func (eniWatcher *ENIWatcher) Stop()

Stop is used to invoke the cancellation routine