Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + func CreateVolumeMessageQueueUpdatePublisherConfiguration(fileSystemSpec *lifetimesapi.OutputFileSystemSpec, ...) (*volumecontrolapi.MessageQueue, error) + type VolumeMessageQueueInitPublisher struct + func NewVolumeMessageQueueInitPublisher(fileSystemSpec *lifetimesapi.OutputFileSystemSpec, ...) (*VolumeMessageQueueInitPublisher, error) + func (vmqip *VolumeMessageQueueInitPublisher) CloseMessageQueues() error + func (vmqip *VolumeMessageQueueInitPublisher) HandleInitQueueMessages(ctx context.Context) error + func (vmqip *VolumeMessageQueueInitPublisher) HasInitialData() (bool, error) + type VolumeMessageQueueUpdatePublisher struct + func NewVolumeMessageQueueUpdatePublisher(messageQueueConfig *messagequeue.MessageQueueConfig, topic string, ...) (*VolumeMessageQueueUpdatePublisher, error) + func (vmqup *VolumeMessageQueueUpdatePublisher) CloseMessageQueue() error + func (vmqup *VolumeMessageQueueUpdatePublisher) CreateDeleteFileMessages(path string) error + func (vmqup *VolumeMessageQueueUpdatePublisher) CreateRenameFileMessages(newPath string, oldPath string) error + func (vmqup *VolumeMessageQueueUpdatePublisher) CreateUpdateFileMessages(path string, offset int64, contents []byte) error
Go to main page