utils

Documentation

Overview

Package utils contains various helpers and utility functions

Index

• func AppendValueToArrowBuilder[IN common.ValueType, OUT common.ValueType, AB common.ArrowBuilder[OUT]](acceptor any, builder array.Builder, ...) error
• func AppendValueToArrowBuilderNullable[IN common.ValueType, OUT common.ValueType, AB common.ArrowBuilder[OUT]](acceptor any, builder array.Builder, ...) error
• func LoggerMustFromContext(ctx context.Context) *zap.Logger
• func MakeAppender[IN common.ValueType, OUT common.ValueType, AB common.ArrowBuilder[OUT]](conv conversion.ValuePtrConverter[IN, OUT]) func(acceptor any, builder array.Builder) error
• func MakeAppenderNullable[IN common.ValueType, OUT common.ValueType, AB common.ArrowBuilder[OUT]](conv conversion.ValuePtrConverter[IN, OUT]) func(acceptor any, builder array.Builder) error
• func StreamServerMetadata(logger *zap.Logger) grpc.StreamServerInterceptor
• func UnaryServerMetadata(logger *zap.Logger) grpc.UnaryServerInterceptor
• type Counter
  • func NewCounter[T number]() *Counter[T]
  • func (c *Counter[T]) Add(delta T)
  • func (c *Counter[T]) MakeChild() *Counter[T]
  • func (c *Counter[T]) Value() T
• type Service

Functions

func AppendValueToArrowBuilder

func AppendValueToArrowBuilder[IN common.ValueType, OUT common.ValueType, AB common.ArrowBuilder[OUT]](
	acceptor any,
	builder array.Builder,
	conv conversion.ValuePtrConverter[IN, OUT],
) error

func AppendValueToArrowBuilderNullable

func AppendValueToArrowBuilderNullable[IN common.ValueType, OUT common.ValueType, AB common.ArrowBuilder[OUT]](
	acceptor any,
	builder array.Builder,
	conv conversion.ValuePtrConverter[IN, OUT],
) error

func LoggerMustFromContext

func LoggerMustFromContext(ctx context.Context) *zap.Logger

func MakeAppender

func MakeAppender[
	IN common.ValueType,
	OUT common.ValueType,
	AB common.ArrowBuilder[OUT],
](conv conversion.ValuePtrConverter[IN, OUT]) func(acceptor any, builder array.Builder) error

func MakeAppenderNullable

func MakeAppenderNullable[
	IN common.ValueType,
	OUT common.ValueType,
	AB common.ArrowBuilder[OUT],
](conv conversion.ValuePtrConverter[IN, OUT]) func(acceptor any, builder array.Builder) error

func StreamServerMetadata

func StreamServerMetadata(logger *zap.Logger) grpc.StreamServerInterceptor

func UnaryServerMetadata

func UnaryServerMetadata(logger *zap.Logger) grpc.UnaryServerInterceptor

Types

type Counter

type Counter[T number] struct {
	// contains filtered or unexported fields
}

func NewCounter

func NewCounter[T number]() *Counter[T]

func (*Counter[T]) Add

func (c *Counter[T]) Add(delta T)

func (*Counter[T]) MakeChild

func (c *Counter[T]) MakeChild() *Counter[T]

func (*Counter[T]) Value

func (c *Counter[T]) Value() T

type Service

type Service interface {
	Start() error
	Stop()
}

Service is an abstract interface representing some internal service running in a distinct thread.