topic

Documentation

Index

• Variables
• func ConvertPartitionsToInt(partitionStr string) (int32, error)
• func ConvertRetentionBytesToInt(retentionBytesStr string) (int, error)
• func ConvertRetentionMsToInt(retentionMsStr string) (int, error)
• func CreateConfigEntries(entryMap map[string]*string) *[]kafkainstanceclient.ConfigEntry
• func ValidateMessageRetentionPeriod(v interface{}) error
• func ValidateMessageRetentionSize(v interface{}) error
• func ValidateName(val interface{}) error
• func ValidateNameIsAvailable(api kafkainstanceclient.DefaultApi, instance string) func(v interface{}) error
• func ValidatePartitionsN(v interface{}) error
• func ValidateSearchInput(val interface{}, localizer localize.Localizer) error

Variables

var RetentionMsKey string = "retention.ms"

var RetentionSizeKey string = "retention.bytes"

Functions

func ConvertPartitionsToInt

func ConvertPartitionsToInt(partitionStr string) (int32, error)

ConvertPartitionsToInt converts the value from "partitions" to int32

func ConvertRetentionBytesToInt

func ConvertRetentionBytesToInt(retentionBytesStr string) (int, error)

ConvertRetentionBytesToInt converts the value from "retention-bytes" to int

func ConvertRetentionMsToInt

func ConvertRetentionMsToInt(retentionMsStr string) (int, error)

ConvertRetentionMsToInt converts the value from "retention-ms" to int

func CreateConfigEntries

func CreateConfigEntries(entryMap map[string]*string) *[]kafkainstanceclient.ConfigEntry

CreateConfigEntries converts a key value map of config entries to an array of config entries

func ValidateMessageRetentionPeriod

func ValidateMessageRetentionPeriod(v interface{}) error

ValidateMessageRetentionPeriod validates the value (ms) of the retention period the valid values can range from [-1,...]

func ValidateMessageRetentionSize

func ValidateMessageRetentionSize(v interface{}) error

ValidateMessageRetentionSize validates the value (bytes) of the retention size the valid values can range from [-1,...]

func ValidateName

func ValidateName(val interface{}) error

ValidateName validates the name of the topic

func ValidateNameIsAvailable

func ValidateNameIsAvailable(api kafkainstanceclient.DefaultApi, instance string) func(v interface{}) error

ValidateNameIsAvailable checks if a topic with the given name already exists

func ValidatePartitionsN

func ValidatePartitionsN(v interface{}) error

ValidatePartitionsN performs validation on the number of partitions v

func ValidateSearchInput

func ValidateSearchInput(val interface{}, localizer localize.Localizer) error