utils

Documentation

Index

• func ExtractJSONField[T any](raw []byte, field string) T
• func PtrTo[T any](v T) *T
• type ConcurrentGroup
  • func NewConcurrentGroup() *ConcurrentGroup
  • func (c *ConcurrentGroup) Go(fn func() error)
  • func (c *ConcurrentGroup) Wait() error

Functions

func ExtractJSONField

func ExtractJSONField[T any](raw []byte, field string) T

ExtractJSONField extracts the stream flag from JSON

func PtrTo

func PtrTo[T any](v T) *T

PtrTo returns a reference to v.

Types

type ConcurrentGroup

type ConcurrentGroup struct {
	// contains filtered or unexported fields
}

ConcurrentGroup is like errgroup.Group but differs in that an error in one goroutine will not interrupt the functioning of another. See https://pkg.go.dev/golang.org/x/sync/errgroup#Group.Go.

func NewConcurrentGroup

func NewConcurrentGroup() *ConcurrentGroup

func (*ConcurrentGroup) Go

func (c *ConcurrentGroup) Go(fn func() error)

func (*ConcurrentGroup) Wait

func (c *ConcurrentGroup) Wait() error