util

Documentation

Index

• Constants
• func AddStackTrace(e error) error
• func Chunks[T any](xs []T, chunkSize int) [][]T
• func EnableErrorStackTrace()
• func Filter[T any](slice []T, f func(T) bool) []T
• func GetStackTrace(e error) string
• func PrintStackTrace(e error, w io.Writer)
• func SendAllFromSlice[T any](ctx context.Context, out chan<- T, items []T) error
• func StartProfiler()

Constants

const MEGABYTE = 1024 * 1024

Functions

func AddStackTrace

func AddStackTrace(e error) error

func Chunks

func Chunks[T any](xs []T, chunkSize int) [][]T

func EnableErrorStackTrace

func EnableErrorStackTrace()

func Filter

func Filter[T any](slice []T, f func(T) bool) []T

func GetStackTrace

func GetStackTrace(e error) string

func PrintStackTrace

func PrintStackTrace(e error, w io.Writer)

func SendAllFromSlice

func SendAllFromSlice[T any](ctx context.Context, out chan<- T, items []T) error

SendAllFromSlice iterates over `items` and sends each one over `out` unless `ctx` is cancelled. Returns ctx.Err() if not all items were written to the channel.

func StartProfiler

func StartProfiler()