Versions in this module Expand all Collapse all v0 v0.0.1 Mar 15, 2022 Changes in this version + const MessageMethodAdd + const MessageMethodDelete + const MessageMethodFinish + const MessageMethodRename + func GetGroupId(persistentVolumeClaimRef *corev1.ObjectReference) string + func GetMessageQueueTopic(pvcNamespace string, pvcName string) *messagequeue.MessageQueueTopic + type Message struct + Contents []byte + Method int8 + Offset int64 + OldPath string + Path string + type MessageQueueUpdatePublisherOperations interface + CreateDeleteFileMessages func(path string) ([]kafka.Message, error) + CreateFinishFileMessages func() ([]kafka.Message, error) + CreateRenameFileMessages func(newPath string, oldPath string) ([]kafka.Message, error) + CreateUpdateFileMessages func(path string, offset int64, contents []byte) ([]kafka.Message, error)
Go to main page