Versions in this module Expand all Collapse all v1 v1.1.1 Oct 17, 2024 v1.1.0 Oct 17, 2024 Changes in this version + const Attachment + const AttachmentMediaType + const AttachmentURL + const DefaultAttempts + const DefaultTimeout + const InReplyTo + const KafkaTopic + const Tag + const TagName + const TagType + const TagTypeHashtag + const TagTypeMention + func MessageTypeStrings() []string + type Client interface + GetKafkaConsumer func() *kgo.Client + func NewClient(endpoint string, kafkaTopic string, offset *int64) (Client, error) + type MessageType int + const MessageTypeAnnounce + const MessageTypeCreate + const MessageTypeLike + const MessageTypeNone + func MessageTypeString(s string) (MessageType, error) + func MessageTypeValues() []MessageType + func (MessageType) Values() []string + func (i MessageType) IsAMessageType() bool + func (i MessageType) String() string