util

Documentation

Index

• func ConvertFromProto(data map[string]*structpb.Value) map[string]any
• func ConvertMapToStructPb(data map[string]any) *structpb.Value
• func ConvertToProto(data map[string]any) map[string]*structpb.Value
• func Shuffle(in []int)
• type EncoderDecoder
• type JsonEncDec
  • func NewJsonEncoderDecoder[T any]() *JsonEncDec[T]
  • func (encdec *JsonEncDec[T]) Decode(data []byte) (*T, error)
  • func (encdec *JsonEncDec[T]) Encode(value T) ([]byte, error)
• type Task
• type TickWorker
  • func NewTickWorker(name string, interval int, stop chan struct{}, fn func(), wg *sync.WaitGroup) *TickWorker
  • func (tw *TickWorker) Start()
  • func (tw *TickWorker) Stop()
• type Worker
  • func NewWorker(name string, wg *sync.WaitGroup, handler func(Task) error, capacity int) *Worker
  • func (w *Worker) Sender() chan<- Task
  • func (w *Worker) Start()
  • func (w *Worker) Stop()

Functions

func ConvertFromProto

func ConvertFromProto(data map[string]*structpb.Value) map[string]any

func ConvertMapToStructPb

func ConvertMapToStructPb(data map[string]any) *structpb.Value

func ConvertToProto

func ConvertToProto(data map[string]any) map[string]*structpb.Value

func Shuffle

func Shuffle(in []int)

Types

type EncoderDecoder

type EncoderDecoder[T any] interface {
	Encode(value T) ([]byte, error)
	Decode(data []byte) (*T, error)
}

type JsonEncDec

type JsonEncDec[T any] struct{}

func NewJsonEncoderDecoder

func NewJsonEncoderDecoder[T any]() *JsonEncDec[T]

func (*JsonEncDec[T]) Decode

func (encdec *JsonEncDec[T]) Decode(data []byte) (*T, error)

func (*JsonEncDec[T]) Encode

func (encdec *JsonEncDec[T]) Encode(value T) ([]byte, error)

type Task

type Task any

type TickWorker

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

func NewTickWorker

func NewTickWorker(name string, interval int, stop chan struct{}, fn func(), wg *sync.WaitGroup) *TickWorker

func (*TickWorker) Start

func (tw *TickWorker) Start()

func (*TickWorker) Stop

func (tw *TickWorker) Stop()

type Worker

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

func NewWorker

func NewWorker(name string, wg *sync.WaitGroup, handler func(Task) error, capacity int) *Worker

func (*Worker) Sender

func (w *Worker) Sender() chan<- Task

func (*Worker) Start

func (w *Worker) Start()

func (*Worker) Stop

func (w *Worker) Stop()