utils

Documentation

Index

• func CalculateRedisStreamMinID(retentionTimeInMs int64) (string, error)
• func FileExists(filepath string) bool
• func GetTimestampFromStreamMessageID(id string) (int64, error)
• func HashString(s string) string
• func IsValidTimeUnitString(value string) bool
• func ParseInt64(s string) int64
• func ParseTimeUnitString(value string) (int, error)
• func SerializeStreamMessageValues(values map[string]interface{}) string

Functions

func CalculateRedisStreamMinID

func CalculateRedisStreamMinID(retentionTimeInMs int64) (string, error)

Calculates the minimum ID for a Redis stream

func FileExists

func FileExists(filepath string) bool

Check if a file exists at the given path

func GetTimestampFromStreamMessageID

func GetTimestampFromStreamMessageID(id string) (int64, error)

Get the timestamp from a Redis stream message ID

func HashString

func HashString(s string) string

func IsValidTimeUnitString

func IsValidTimeUnitString(value string) bool

func ParseInt64

func ParseInt64(s string) int64

func ParseTimeUnitString

func ParseTimeUnitString(value string) (int, error)

Parses a time unit string into a duration in seconds

func SerializeStreamMessageValues

func SerializeStreamMessageValues(values map[string]interface{}) string