common

Documentation

Index

• Constants
• Variables
• func Expensive(f func() slog.Value) slog.LogValuer
• func LogCounter() slog.LogValuer
• func OptionalStr(s string) *string
• func ReceiveFromChannel[T any](ctx context.Context, c <-chan T) (T, bool)
• func RunProcess(startProcess func() (io.Closer, error))
• func SendToChannel[T any](ctx context.Context, c chan<- T, e interface{}) bool
• func WaitUntilSignal(closers ...io.Closer)
• type BufferReader
  • func NewChanReader() *BufferReader
  • func (r *BufferReader) Read(p []byte) (n int, err error)
  • func (r *BufferReader) ResetBuffer(data []byte)
• type BufferWriter
  • func NewChanWriter() *BufferWriter
  • func (w *BufferWriter) GetAndReset() []byte
  • func (w *BufferWriter) Write(p []byte) (n int, err error)
• type ConfigMap
  • func MergeConfig(configs ...*ConfigMap) *ConfigMap
• type Logger
  • func NewDefaultLogger() *Logger
  • func NewLogger(logger *logr.Logger) *Logger
  • func (l *Logger) Debug(msg string, keysAndValues ...interface{})
  • func (l *Logger) DebugEnabled() bool
  • func (l *Logger) SubLogger(keysAndValues ...any) *Logger

Constants

const (
	PulsarTubeType = "pulsar"
	MemoryTubeType = "memory"
	HttpTubeType   = "http"

	WASMRuntime = "wasm"

	RuntimeArchiveConfigKey = "archive"

	StateStorePebble = "pebble"
)

const (
	DebugLevel int = 4
)

Variables

var (
	ErrorFunctionNotFound       = fmt.Errorf("function not found")
	ErrorFunctionExists         = fmt.Errorf("function already exists")
	ErrorRuntimeFactoryNotFound = fmt.Errorf("runtime factory not found")
	ErrorTubeFactoryNotFound    = fmt.Errorf("tube factory not found")
)

Functions

func Expensive

func Expensive(f func() slog.Value) slog.LogValuer

func LogCounter

func LogCounter() slog.LogValuer

func OptionalStr

func OptionalStr(s string) *string

func ReceiveFromChannel

func ReceiveFromChannel[T any](ctx context.Context, c <-chan T) (T, bool)

func RunProcess

func RunProcess(startProcess func() (io.Closer, error))

func SendToChannel

func SendToChannel[T any](ctx context.Context, c chan<- T, e interface{}) bool

func WaitUntilSignal

func WaitUntilSignal(closers ...io.Closer)

Types

type BufferReader

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

func NewChanReader

func NewChanReader() *BufferReader

func (*BufferReader) Read

func (r *BufferReader) Read(p []byte) (n int, err error)

func (*BufferReader) ResetBuffer

func (r *BufferReader) ResetBuffer(data []byte)

type BufferWriter

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

func NewChanWriter

func NewChanWriter() *BufferWriter

func (*BufferWriter) GetAndReset

func (w *BufferWriter) GetAndReset() []byte

func (*BufferWriter) Write

func (w *BufferWriter) Write(p []byte) (n int, err error)

type ConfigMap

type ConfigMap map[string]interface{}

func MergeConfig

func MergeConfig(configs ...*ConfigMap) *ConfigMap

MergeConfig merges multiple ConfigMap into one

type Logger

type Logger struct {
	*logr.Logger
}

func NewDefaultLogger

func NewDefaultLogger() *Logger

func NewLogger

func NewLogger(logger *logr.Logger) *Logger

func (*Logger) Debug

func (l *Logger) Debug(msg string, keysAndValues ...interface{})

func (*Logger) DebugEnabled

func (l *Logger) DebugEnabled() bool

func (*Logger) SubLogger

func (l *Logger) SubLogger(keysAndValues ...any) *Logger