publish

Documentation

Index

• func CreateVolumeMessageQueueUpdatePublisherConfiguration(fileSystemSpec *lifetimesapi.OutputFileSystemSpec, ...) (*volumecontrolapi.MessageQueue, error)
• type VolumeMessageQueueInitPublisher
  • 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
  • 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

Functions

func CreateVolumeMessageQueueUpdatePublisherConfiguration

func CreateVolumeMessageQueueUpdatePublisherConfiguration(
	fileSystemSpec *lifetimesapi.OutputFileSystemSpec,
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.PublishMessageQueueSpec,
	messageQueuePublisherOptions *messagepub.MessageQueuePublisherOptions) (
	*volumecontrolapi.MessageQueue, error)

Types

type VolumeMessageQueueInitPublisher

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

func NewVolumeMessageQueueInitPublisher

func NewVolumeMessageQueueInitPublisher(
	fileSystemSpec *lifetimesapi.OutputFileSystemSpec,
	publishOptions *messagepub.MessageQueuePublisherOptions,
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.MessageQueueSpec, volumeRootPath string) (
	*VolumeMessageQueueInitPublisher, error)

func (*VolumeMessageQueueInitPublisher) CloseMessageQueues

func (vmqip *VolumeMessageQueueInitPublisher) CloseMessageQueues() error

func (*VolumeMessageQueueInitPublisher) HandleInitQueueMessages

func (vmqip *VolumeMessageQueueInitPublisher) HandleInitQueueMessages(
	ctx context.Context) error

func (*VolumeMessageQueueInitPublisher) HasInitialData

func (vmqip *VolumeMessageQueueInitPublisher) HasInitialData() (bool, error)

type VolumeMessageQueueUpdatePublisher

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

func NewVolumeMessageQueueUpdatePublisher

func NewVolumeMessageQueueUpdatePublisher(
	messageQueueConfig *messagequeue.MessageQueueConfig, topic string,
	compressionCodecOption string, volumeRootPath string, maxBatchBytes int,
	channelBufferSize int) (
	*VolumeMessageQueueUpdatePublisher, error)

func (*VolumeMessageQueueUpdatePublisher) CloseMessageQueue

func (vmqup *VolumeMessageQueueUpdatePublisher) CloseMessageQueue() error

func (*VolumeMessageQueueUpdatePublisher) CreateDeleteFileMessages

func (vmqup *VolumeMessageQueueUpdatePublisher) CreateDeleteFileMessages(
	path string) error

func (*VolumeMessageQueueUpdatePublisher) CreateRenameFileMessages

func (vmqup *VolumeMessageQueueUpdatePublisher) CreateRenameFileMessages(
	newPath string, oldPath string) error

func (*VolumeMessageQueueUpdatePublisher) CreateUpdateFileMessages

func (vmqup *VolumeMessageQueueUpdatePublisher) CreateUpdateFileMessages(
	path string, offset int64, contents []byte) error