helpers

Documentation

Index

• Constants
• func ChunkSlice[T any](slice []T, chunks int) [][]T
• func ChunkSliceWithSize[T any](slice []T, chunkSize int) [][]T
• func IsMetadata(data interface{}) bool
• func ResolveUnionIntOrStringValue(input any) int
• func Retry(f func() error, attempts int, sleep time.Duration) (err error)

Constants

const (
	Prefix    string = "_connector:" + Name + ":"
	TxnPrefix string = "_txn:"

	MembershipChangedBusEventName   string = "membershipChanged"
	PersistSeqNoChangedBusEventName string = "persistSeqNoChanged"

	JSONFlags uint32 = 50333696
)

const Name = "cbgo"

Functions

func ChunkSlice

func ChunkSlice[T any](slice []T, chunks int) [][]T

func ChunkSliceWithSize

func ChunkSliceWithSize[T any](slice []T, chunkSize int) [][]T

func IsMetadata

func IsMetadata(data interface{}) bool

func ResolveUnionIntOrStringValue

func ResolveUnionIntOrStringValue(input any) int

func Retry

func Retry(f func() error, attempts int, sleep time.Duration) (err error)