util

Documentation

Index

• Constants
• func ContainsInt32(list []int32, element int32) bool
• func ContainsString(list []string, element string) bool
• func ConvertControlChars(value string) string
• func ExtractOffsetForPartition(rawOffsets []string, currentPartition int32) (int64, error)
• func LoadPlugin[P plugin.Plugin, I any](pluginName string, pluginSpec plugins.PluginSpec[P, I]) (impl I, err error)
• func ParseOffsets(rawOffsets []string) (map[int32]int64, error)
• func ParseTimestamp(timestamp string) (time.Time, error)
• func StringArraysEqual(a, b []string) bool

Constants

const ErrOffset = math.MinInt64

Functions

func ContainsInt32

func ContainsInt32(list []int32, element int32) bool

func ContainsString

func ContainsString(list []string, element string) bool

func ConvertControlChars

func ConvertControlChars(value string) string

func ExtractOffsetForPartition

func ExtractOffsetForPartition(rawOffsets []string, currentPartition int32) (int64, error)

func LoadPlugin

func LoadPlugin[P plugin.Plugin, I any](pluginName string, pluginSpec plugins.PluginSpec[P, I]) (impl I, err error)

func ParseOffsets

func ParseOffsets(rawOffsets []string) (map[int32]int64, error)

func ParseTimestamp

func ParseTimestamp(timestamp string) (time.Time, error)

func StringArraysEqual

func StringArraysEqual(a, b []string) bool