util

Documentation

Index

• Constants
• type BitSet
  • func (bs *BitSet) Count() int
  • func (bs *BitSet) Set(idx int)
• type Sender
• type Stream
• type StreamReader
  • func ProcessStream[T any, U any](ctx context.Context, stream Stream[T], sender Sender[U], ...) StreamReader
  • func ReadStream[T any](ctx context.Context, stream Stream[T], handleMessage func(*T) error, ...) StreamReader

Constants

const MaxBitSetSize = 16

Types

type BitSet

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

BitSet Simplified and compact bitset.

func (*BitSet) Count

func (bs *BitSet) Count() int

func (*BitSet) Set

func (bs *BitSet) Set(idx int)

type Sender

type Sender[U any] interface {
	Send(message *U) error
}

type Stream

type Stream[T any] interface {
	Recv() (*T, error)
}

type StreamReader

type StreamReader interface {
	Run() error
}

func ProcessStream

func ProcessStream[T any, U any](
	ctx context.Context,
	stream Stream[T],
	sender Sender[U],
	handleMessage func(*T) (*U, error),
	labels map[string]string,
	log *slog.Logger) StreamReader

func ReadStream

func ReadStream[T any](
	ctx context.Context,
	stream Stream[T],
	handleMessage func(*T) error,
	labels map[string]string,
	log *slog.Logger) StreamReader