subscribe

package

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

Documentation ¶

Index ¶

type MessageQueueInitSubscriber
- func NewMessageQueueInitSubscriber(dataClient coreclientset.Interface, kubeClient kubernetes.Interface, ...) (*MessageQueueInitSubscriber, error)
type MessageQueueInitSubscriberOperations
type MessageQueueUpdateSubscriber
- func NewMessageQueueUpdateSubscriber(dataClient coreclientset.Interface, kubeClient kubernetes.Interface, ...) (*MessageQueueUpdateSubscriber, error)
type MessageQueueUpdateSubscriberOperations

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type MessageQueueInitSubscriber ¶

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

func NewMessageQueueInitSubscriber ¶

func NewMessageQueueInitSubscriber(
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	spec *lifetimesapi.MessageQueueSpec, topic *messagequeue.MessageQueueTopic,
	groupId string) (*MessageQueueInitSubscriber, error)

func (*MessageQueueInitSubscriber) AddStorageOps ¶

func (mqis *MessageQueueInitSubscriber) AddStorageOps(
	storageOps MessageQueueInitSubscriberOperations)

func (*MessageQueueInitSubscriber) CloseMessageQueues ¶

func (mqis *MessageQueueInitSubscriber) CloseMessageQueues() error

func (*MessageQueueInitSubscriber) HandleQueueMessages ¶

func (mqis *MessageQueueInitSubscriber) HandleQueueMessages(
	ctx context.Context) (time.Time, error)

type MessageQueueInitSubscriberOperations ¶

type MessageQueueInitSubscriberOperations interface {
	HandleInitMessage(queueMessage *kafka.Message) (bool, error)
}

type MessageQueueUpdateSubscriber ¶

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

func NewMessageQueueUpdateSubscriber ¶

func NewMessageQueueUpdateSubscriber(
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	spec *lifetimesapi.MessageQueueSpec, topic *messagequeue.MessageQueueTopic,
	groupId string) (*MessageQueueUpdateSubscriber, error)

func (*MessageQueueUpdateSubscriber) AddStorageOps ¶

func (mqus *MessageQueueUpdateSubscriber) AddStorageOps(
	storageOps MessageQueueUpdateSubscriberOperations)

func (*MessageQueueUpdateSubscriber) CloseMessageQueue ¶

func (mqus *MessageQueueUpdateSubscriber) CloseMessageQueue() error

func (*MessageQueueUpdateSubscriber) HandleFirstQueueMessage ¶

func (mqus *MessageQueueUpdateSubscriber) HandleFirstQueueMessage(
	ctx context.Context, offsetTime time.Time) (bool, error)

func (*MessageQueueUpdateSubscriber) HandleQueueMessage ¶

func (mqus *MessageQueueUpdateSubscriber) HandleQueueMessage(
	ctx context.Context) (bool, error)

type MessageQueueUpdateSubscriberOperations ¶

type MessageQueueUpdateSubscriberOperations interface {
	HandleUpdateMessage(queueMessage *kafka.Message) (bool, error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
testing

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