util

Documentation

Index

• func Iterate[T any](ctx context.Context, handle func(ctx context.Context, data T) error, ...) error
• func Retry(fn func() error, pause time.Duration, maxRetries int) error
• func RetryWithResult[T any](fn func() (T, error), pause time.Duration, maxRetries int) (T, error)
• func SubscriptionEventFromPb(data *managementpb.Event) (*dto.SubscriptionEvent, error)
• func SubscriptionEventsFromPb(data []*managementpb.Event) ([]*dto.SubscriptionEvent, error)

Functions

func Iterate

func Iterate[T any](
	ctx context.Context,
	handle func(ctx context.Context, data T) error,
	loadData func(ctx context.Context, page int, perPage int) ([]T, error),
	stopLoadingMore func(ctx context.Context, data T) bool,
	perPage int,
	queueSize int,
) error

func Retry

func Retry(fn func() error, pause time.Duration, maxRetries int) error

func RetryWithResult

func RetryWithResult[T any](fn func() (T, error), pause time.Duration, maxRetries int) (T, error)

func SubscriptionEventFromPb

func SubscriptionEventFromPb(data *managementpb.Event) (*dto.SubscriptionEvent, error)

func SubscriptionEventsFromPb

func SubscriptionEventsFromPb(data []*managementpb.Event) ([]*dto.SubscriptionEvent, error)