subscribe

package

v0.0.1 Latest Latest Go to latest Published: Mar 15, 2022 License: MIT Imports: 13 Imported by: 0

Documentation ¶

Index ¶

type VolumeMessageQueueInitSubscriber
- func NewVolumeMessageQueueInitSubscriber(fileSystemSpec *lifetimesapi.InputFileSystemSpec, ...) (*VolumeMessageQueueInitSubscriber, error)
- func (vmqis *VolumeMessageQueueInitSubscriber) CloseMessageQueues() error
- func (vmqis *VolumeMessageQueueInitSubscriber) HandleQueueMessages(ctx context.Context) (time.Time, error)
type VolumeMessageQueueUpdateSubscriber
- func NewVolumeMessageQueueUpdateSubscriber(fileSystemSpec *lifetimesapi.InputFileSystemSpec, ...) (*VolumeMessageQueueUpdateSubscriber, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type VolumeMessageQueueInitSubscriber ¶

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

func NewVolumeMessageQueueInitSubscriber ¶

func NewVolumeMessageQueueInitSubscriber(
	fileSystemSpec *lifetimesapi.InputFileSystemSpec,
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.MessageQueueSpec, volumeRootPath string) (
	*VolumeMessageQueueInitSubscriber, error)

func (*VolumeMessageQueueInitSubscriber) CloseMessageQueues ¶

func (vmqis *VolumeMessageQueueInitSubscriber) CloseMessageQueues() error

func (*VolumeMessageQueueInitSubscriber) HandleQueueMessages ¶

func (vmqis *VolumeMessageQueueInitSubscriber) HandleQueueMessages(
	ctx context.Context) (time.Time, error)

type VolumeMessageQueueUpdateSubscriber ¶

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

func NewVolumeMessageQueueUpdateSubscriber ¶

func NewVolumeMessageQueueUpdateSubscriber(
	fileSystemSpec *lifetimesapi.InputFileSystemSpec,
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.MessageQueueSpec, volumeRootPath string) (
	*VolumeMessageQueueUpdateSubscriber, error)

func (*VolumeMessageQueueUpdateSubscriber) CloseMessageQueue ¶

func (vmqus *VolumeMessageQueueUpdateSubscriber) CloseMessageQueue() error

func (*VolumeMessageQueueUpdateSubscriber) HandleFirstQueueMessage ¶

func (vmqus *VolumeMessageQueueUpdateSubscriber) HandleFirstQueueMessage(
	ctx context.Context, offsetTime time.Time) (bool, error)

func (*VolumeMessageQueueUpdateSubscriber) HandleQueueMessage ¶

func (vmqus *VolumeMessageQueueUpdateSubscriber) HandleQueueMessage(
	ctx context.Context) (bool, error)

Source Files ¶

View all Source files

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