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 ¶
View Source
const ErrOffset = math.MinInt64
Variables ¶
This section is empty.
Functions ¶
func ContainsInt32 ¶
func ContainsString ¶
func ConvertControlChars ¶
func LoadPlugin ¶ added in v5.0.3
func LoadPlugin[P plugin.Plugin, I any](pluginName string, pluginSpec plugins.PluginSpec[P, I]) (impl I, err error)
func StringArraysEqual ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.