subscribe

Documentation

Index

• type MessageQueueInitSubscriber
  • func NewMessageQueueInitSubscriber(dataClient coreclientset.Interface, kubeClient kubernetes.Interface, ...) (*MessageQueueInitSubscriber, error)
  • func (mqis *MessageQueueInitSubscriber) AddStorageOps(storageOps MessageQueueInitSubscriberOperations)
  • func (mqis *MessageQueueInitSubscriber) CloseMessageQueues() error
  • func (mqis *MessageQueueInitSubscriber) HandleQueueMessages(ctx context.Context) (time.Time, error)
• type MessageQueueInitSubscriberOperations
• type MessageQueueUpdateSubscriber
  • func NewMessageQueueUpdateSubscriber(dataClient coreclientset.Interface, kubeClient kubernetes.Interface, ...) (*MessageQueueUpdateSubscriber, error)
  • func (mqus *MessageQueueUpdateSubscriber) AddStorageOps(storageOps MessageQueueUpdateSubscriberOperations)
  • func (mqus *MessageQueueUpdateSubscriber) CloseMessageQueue() error
  • func (mqus *MessageQueueUpdateSubscriber) HandleFirstQueueMessage(ctx context.Context, offsetTime time.Time) (bool, error)
  • func (mqus *MessageQueueUpdateSubscriber) HandleQueueMessage(ctx context.Context) (bool, error)
• type MessageQueueUpdateSubscriberOperations

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)
}