namingstrategy

Documentation

Index

• func NewNamingStrategy(name config.NamingStrategyType, config *config.Config) (namingstrategy.NamingStrategy, error)
• func RegisterNamingStrategy(name config.NamingStrategyType, factory namingstrategy.Factory) bool
• func SanitizeTopicName(topicName string) (topic string, changed bool)

Functions

func NewNamingStrategy

func NewNamingStrategy(
	name config.NamingStrategyType, config *config.Config,
) (namingstrategy.NamingStrategy, error)

NewNamingStrategy instantiates a new instance of the requested NamingStrategy when available, otherwise returns an error.

func RegisterNamingStrategy

func RegisterNamingStrategy(
	name config.NamingStrategyType, factory namingstrategy.Factory,
) bool

RegisterNamingStrategy registers a NamingRegistryType to a Provider implementation which creates the NamingStrategy when requested

func SanitizeTopicName

func SanitizeTopicName(
	topicName string,
) (topic string, changed bool)

SanitizeTopicName is a helper to sanitize topic names to be as compatible as possible