gstream

Documentation

Index

• type BatcherFunc
• type DynamicSizeCache
  • func NewDynamicSizeCache[T Sizable, M any](s WStream[M], maxSize int, bf BatcherFunc[T, *M]) *DynamicSizeCache[T, M]
  • func (d *DynamicSizeCache[T, M]) Context() context.Context
  • func (d *DynamicSizeCache[T, M]) Flush() error
  • func (d *DynamicSizeCache[T, M]) Queue(ts ...T) error
• type RStream
• type Sizable
• type WStream
  • func Wrap[In, Out any](original WStream[Out], mapper func(*In) *Out) WStream[In]

Types

type BatcherFunc

type BatcherFunc[S, D any] func(t []S) (D, error)

type DynamicSizeCache

type DynamicSizeCache[T Sizable, M any] struct {
	// contains filtered or unexported fields
}

func NewDynamicSizeCache

func NewDynamicSizeCache[T Sizable, M any](s WStream[M], maxSize int, bf BatcherFunc[T, *M]) *DynamicSizeCache[T, M]

func (*DynamicSizeCache[T, M]) Context

func (d *DynamicSizeCache[T, M]) Context() context.Context

func (*DynamicSizeCache[T, M]) Flush

func (d *DynamicSizeCache[T, M]) Flush() error

func (*DynamicSizeCache[T, M]) Queue

func (d *DynamicSizeCache[T, M]) Queue(ts ...T) error

type RStream

type RStream[T any] interface {
	Recv() (*T, error)
	Context() context.Context
}

type Sizable

type Sizable interface {
	EstimateSize() int
}

type WStream

type WStream[T any] interface {
	Send(*T) error
	Context() context.Context
}

func Wrap

func Wrap[In, Out any](original WStream[Out], mapper func(*In) *Out) WStream[In]