messagequeue

Documentation

Index

• Constants
• func GetGroupId(persistentVolumeClaimRef *corev1.ObjectReference) string
• func GetMessageQueueTopic(pvcNamespace string, pvcName string) *messagequeue.MessageQueueTopic
• type Message
• type MessageQueueUpdatePublisherOperations

Constants

const (
	MessageMethodAdd = iota + 1
	MessageMethodDelete
	MessageMethodRename
	MessageMethodFinish
)

Functions

func GetGroupId

func GetGroupId(persistentVolumeClaimRef *corev1.ObjectReference) string

func GetMessageQueueTopic

func GetMessageQueueTopic(
	pvcNamespace string, pvcName string) *messagequeue.MessageQueueTopic

Types

type Message

type Message struct {
	Method   int8   `json:"method"`
	Path     string `json:"path,omitempty"`
	OldPath  string `json:"oldPath,omitempty"`
	Offset   int64  `json:"offset,omitempty"`
	Contents []byte `json:"contents,omitempty"`
}

type MessageQueueUpdatePublisherOperations

type MessageQueueUpdatePublisherOperations interface {
	CreateUpdateFileMessages(
		path string, offset int64, contents []byte) ([]kafka.Message, error)
	CreateDeleteFileMessages(path string) ([]kafka.Message, error)
	CreateRenameFileMessages(
		newPath string, oldPath string) ([]kafka.Message, error)
	CreateFinishFileMessages() ([]kafka.Message, error)
}