watcher

package
v0.0.0-...-9ec3720 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 6, 2021 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewFilesystemAttachmentsWatcher

func NewFilesystemAttachmentsWatcher(caller base.APICaller, result params.MachineStorageIdsWatchResult) watcher.MachineStorageIdsWatcher

NewFilesystemAttachmentsWatcher returns a MachineStorageIdsWatcher which communicates with the FilesystemAttachmentsWatcher API facade to watch filesystem attachments.

func NewMigrationStatusWatcher

func NewMigrationStatusWatcher(caller base.APICaller, watcherId string) watcher.MigrationStatusWatcher

NewMigrationStatusWatcher takes the NotifyWatcherId returns by the MigrationSlave.Watch API and returns a watcher which will report status changes for any migration of the model associated with the API connection.

func NewNotifyWatcher

func NewNotifyWatcher(caller base.APICaller, result params.NotifyWatchResult) watcher.NotifyWatcher

If an API call returns a NotifyWatchResult, you can use this to turn it into a local Watcher.

func NewOfferStatusWatcher

func NewOfferStatusWatcher(
	caller base.APICaller, result params.OfferStatusWatchResult,
) watcher.OfferStatusWatcher

NewOfferStatusWatcher returns a watcher notifying of changes to offer status.

func NewRelationStatusWatcher

NewRelationStatusWatcher returns a watcher notifying of changes to relation life and suspended status.

func NewStringsWatcher

func NewStringsWatcher(caller base.APICaller, result params.StringsWatchResult) watcher.StringsWatcher

func NewVolumeAttachmentPlansWatcher

func NewVolumeAttachmentPlansWatcher(caller base.APICaller, result params.MachineStorageIdsWatchResult) watcher.MachineStorageIdsWatcher

NewVolumeAttachmentPlansWatcher returns a MachineStorageIdsWatcher which communicates with the VolumeAttachmentPlansWatcher API facade to watch volume attachments.

func NewVolumeAttachmentsWatcher

func NewVolumeAttachmentsWatcher(caller base.APICaller, result params.MachineStorageIdsWatchResult) watcher.MachineStorageIdsWatcher

NewVolumeAttachmentsWatcher returns a MachineStorageIdsWatcher which communicates with the VolumeAttachmentsWatcher API facade to watch volume attachments.

Types

type RemoteRelationWatcher

type RemoteRelationWatcher interface {
	watcher.CoreWatcher
	Changes() <-chan params.RemoteRelationChangeEvent
}

RemoteRelationWatcher is a worker that emits remote relation change events. It's not defined in core/watcher because it emits params structs - this makes more sense than converting to a core struct just to convert back when the event is published to the other model's API.

func NewRemoteRelationCompatWatcher

func NewRemoteRelationCompatWatcher(
	caller base.APICaller,
	result params.RelationUnitsWatchResult,
	relationToken string,
	appToken string,
	getSettings SettingsGetter,
) RemoteRelationWatcher

NewRemoteRelationCompatWatcher returns a RemoteRelationWatcher based on a server-side RelationUnitsWatcher.

func NewRemoteRelationWatcher

func NewRemoteRelationWatcher(caller base.APICaller, result params.RemoteRelationWatchResult) RemoteRelationWatcher

NewRemoteRelationWatcher returns a RemoteRelationWatcher receiving events from the one running on the API server.

type SettingsGetter

type SettingsGetter func([]string) ([]params.SettingsResult, error)

SettingsGetter is a callback function the remote relation compatibility watcher calls to get unit settings when expanding events.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL