util

Apr 1, 2024

Changes in this version

+ func NormalizeKafkaPartitions(p []int32) []int32

Sep 18, 2023

Changes in this version

+ func HashToInt(s string) int32

Sep 16, 2023

Changes in this version

+ func MapMerge(ms ...map[K]V) map[K]V

Sep 4, 2023

Changes in this version

+ func CalcPartition(hash, partitions uint32) uint32

+ func IfZero(test, def T) T

+ func NewID() ulid.ULID

+ func NormalizePartitions(p []int32) []uint32

+ type Atomic struct

+ func (a *Atomic) Lock(fn func())

+ func (a *Atomic) RLock(fn func())

+ type Channel struct

+ func NewChannel(size int) *Channel[T]

+ func (c *Channel[T]) Close()

+ func (c *Channel[T]) Push(v T)

+ func (c *Channel[T]) Range(fn func(T))

Jul 25, 2023

Changes in this version

+ func Int32ring(x uint32) int32

type Topic

+ func (t Topic) IsZero() bool

Dec 19, 2022

Changes in this version

+ func Dereference(i interface{}) interface

+ func Hash(s string) uint32

+ func In(test string, values ...string) bool

+ func MustNewULID() ulid.ULID

+ func NewULID() (ulid.ULID, error)

+ func WhichPartition(hash, partitions uint32) uint32

+ type Clock struct

+ func NewClock() *Clock

+ func NewClockAfter(t time.Time) *Clock

+ func (c *Clock) After(after time.Time) time.Time

+ func (c *Clock) Now() time.Time

+ type Clocker interface

+ After func(t time.Time) time.Time

+ Now func() time.Time

+ type Topic struct

+ func NewPartitionedTopic(root string, partition uint32) Topic

+ func NewTopic(root string) Topic

+ func PartitionTopic(topic string, hash, partitions uint32) Topic

+ func (t Topic) Partition() uint32

+ func (t Topic) Root() string

+ func (t Topic) String() string