Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + type VolumeMessageQueueInitSubscriber struct + func NewVolumeMessageQueueInitSubscriber(fileSystemSpec *lifetimesapi.InputFileSystemSpec, ...) (*VolumeMessageQueueInitSubscriber, error) + func (vmqis *VolumeMessageQueueInitSubscriber) CloseMessageQueues() error + func (vmqis *VolumeMessageQueueInitSubscriber) HandleQueueMessages(ctx context.Context) (time.Time, error) + type VolumeMessageQueueUpdateSubscriber struct + func NewVolumeMessageQueueUpdateSubscriber(fileSystemSpec *lifetimesapi.InputFileSystemSpec, ...) (*VolumeMessageQueueUpdateSubscriber, error) + func (vmqus *VolumeMessageQueueUpdateSubscriber) CloseMessageQueue() error + func (vmqus *VolumeMessageQueueUpdateSubscriber) HandleFirstQueueMessage(ctx context.Context, offsetTime time.Time) (bool, error) + func (vmqus *VolumeMessageQueueUpdateSubscriber) HandleQueueMessage(ctx context.Context) (bool, error)