helpers

Documentation

Index

• Constants
• func ChunkSlice[T any](slice []T, chunks int) [][]T
• func IsMetadata(data interface{}) bool
• func Retry(f func() error, attempts int, sleep time.Duration) (err error)
• type Bus
  • func NewBus() Bus
• type Listener

Constants

const (
	Prefix = "_connector:" + Name + ":"

	MembershipChangedBusEventName   = "membershipChanged"
	PersistSeqNoChangedBusEventName = "persistSeqNoChanged"
)

const Name = "cbgo"

Functions

func ChunkSlice

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

func IsMetadata

func IsMetadata(data interface{}) bool

func Retry

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

Types

type Bus

type Bus interface {
	Emit(eventName string, event interface{})
	Subscribe(eventName string, listener Listener)
}

func NewBus

func NewBus() Bus

type Listener

type Listener = func(event interface{})