util

Documentation

Index

• Constants
• func AppendKafkaChannelServiceNameSuffix(channelName string) string
• func GroupId(uid string) string
• func TopicName(namespace string, name string) string
• func TrimKafkaChannelServiceNameSuffix(serviceName string) string
• func Uid(groupId string) types.UID

Constants

const GroupIdPrefix = "kafka"

Functions

func AppendKafkaChannelServiceNameSuffix

func AppendKafkaChannelServiceNameSuffix(channelName string) string

AppendKafkaChannelServiceNameSuffix appends the KafkaChannel Service name suffix to the specified string.

func GroupId

func GroupId(uid string) string

GroupId returns a formatted string representing the Kafka ConsumerGroup ID.

func TopicName

func TopicName(namespace string, name string) string

TopicName returns a formatted string representing the Kafka Topic name.

func TrimKafkaChannelServiceNameSuffix

func TrimKafkaChannelServiceNameSuffix(serviceName string) string

TrimKafkaChannelServiceNameSuffix removes the KafkaChannel Service name suffix from the specified string.

func Uid

func Uid(groupId string) types.UID

Uid returns a UID from the specified GroupId, which is the inverse of GroupId().