Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

common

package

Go to main page

Versions in this module

v0

v0.5.0

Jun 13, 2024

Changes in this version

+ const DebugLevel

+ type Logger struct

+ 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

v0.4.0

May 7, 2024

Changes in this version

+ const StateStorePebble

+ const WASMRuntime

+ type ConfigMap map[string]interface

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

v0.3.0

Mar 8, 2024

Changes in this version

+ const DefaultAddr

+ const DefaultPulsarURL

+ const DefaultTubeType

+ const HttpTubeType

+ const MemoryTubeType

+ const PulsarTubeType

+ const RuntimeArchiveConfigKey

+ var ErrorFunctionExists = errors.New("function already exists")

+ var ErrorFunctionNotFound = errors.New("function not found")

+ var ErrorRuntimeFactoryNotFound = errors.New("runtime factory not found")

+ var ErrorTubeFactoryNotFound = errors.New("tube factory not found")

+ 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 struct

+ func NewChanReader() *BufferReader

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

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

+ type BufferWriter struct

+ func NewChanWriter() *BufferWriter

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

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

+ type Config struct

+ ListenAddr string

+ PulsarURL string

+ TubeType string