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

context

package

Go to main page

Versions in this module

v0

v0.1.5

Dec 31, 2025

v0.1.4

Dec 24, 2025

v0.1.3

Dec 15, 2025

v0.1.2

Dec 14, 2025

v0.1.1

Dec 14, 2025

Changes in this version

+ func GetHelmValuesFromCache(ctx Context, namespace, releaseName string) (map[string]any, error)

v0.1.0

Oct 27, 2025

Changes in this version

+ var CelEnvFuncs = make(map[string]func(Context) cel.EnvOption)

+ var ErrNotFound = errors.New("NOT_FOUND")

+ var LatencyBuckets = []float64

+ var LongLatencyBuckets = []float64

+ var MetricsLogLevel = 5

+ var ShortLatencyBuckets = []float64

+ var TemplateFuncs = make(map[string]func(Context) any)

+ func FindConnection(ctx Context, name, namespace string) (*models.Connection, error)

+ func FindConnectionByURL(ctx Context, connectionString string) (*models.Connection, error)

+ func GetConfigMapFromCache(ctx Context, namespace, name, key string) (string, error)

+ func GetConnection(ctx Context, name, namespace string) (*models.Connection, error)

+ func GetEnvStringFromCache(ctx Context, env string, namespace string) (string, error)

+ func GetEnvValueFromCache(ctx Context, input types.EnvVar, namespace string) (value string, err error)

+ func GetHelmValueFromCache(ctx Context, namespace, releaseName, key string) (string, error)

+ func GetSecretFromCache(ctx Context, namespace, name, key string) (string, error)

+ func GetServiceAccountTokenFromCache(ctx Context, namespace, serviceAccount string) (string, error)

+ func HydrateConnection(ctx Context, connection *models.Connection) (*models.Connection, error)

+ func HydrateConnectionByURL(ctx Context, connectionString string) (*models.Connection, error)

+ func IsValidConnectionURL(connectionString string) bool

+ func Objects(k gocontext.Context) []any

+ func UpdateProperties(ctx Context, props map[string]string) error

+ func UpdateProperty(ctx Context, key, value string) error

+ type AnnotationsAccessor interface

+ GetAnnotations func() map[string]string

+ type Context struct

+ func New(opts ...commons.ContextOptions) Context

+ func NewContext(baseCtx gocontext.Context, opts ...commons.ContextOptions) Context

+ func (ctx Context) GetConnection(name, namespace string) (*models.Connection, error)

+ func (ctx Context) Lookup(namespace string) *EnvVarSourceBuilder

+ func (k Context) ClearCache()

+ func (k Context) ConnectionString() string

+ func (k Context) Counter(name string, labels ...string) Counter

+ func (k Context) DB() *gorm.DB

+ func (k Context) Fast(name ...string) Context

+ func (k Context) FastDB(name ...string) *gorm.DB

+ func (k Context) Gauge(name string, labels ...string) Gauge

+ func (k Context) GetAnnotations() map[string]string

+ func (k Context) GetConfigMapFromCache(namespace, name, key string) (string, error)

+ func (k Context) GetEnvStringFromCache(env string, namespace string) (string, error)

+ func (k Context) GetEnvValueFromCache(input types.EnvVar, namespace string) (string, error)

+ func (k Context) GetLabels() map[string]string

+ func (k Context) GetLoggingContext() map[string]any

+ func (k Context) GetName() string

+ func (k Context) GetNamespace() string

+ func (k Context) GetObjectMeta() metav1.ObjectMeta

+ func (k Context) GetSecretFromCache(namespace, name, key string) (string, error)

+ func (k Context) Histogram(name string, buckets []float64, labels ...string) Histogram

+ func (k Context) HydrateConnection(connection *models.Connection) (*models.Connection, error)

+ func (k Context) HydrateConnectionByURL(connectionString string) (*models.Connection, error)

+ func (k Context) IsTracing() bool

+ func (k Context) KubeAuthFingerprint() string

+ func (k Context) Kubernetes() (*dutyKubernetes.Client, error)

+ func (k Context) KubernetesConnection() KubernetesConnection

+ func (k Context) LocalKubernetes(kubeconfigPaths ...string) (*dutyKubernetes.Client, error)

+ func (k Context) NewStructTemplater(vals map[string]any, requiredTag string, funcs map[string]any) gomplate.StructTemplater

+ func (k Context) Objects() []any

+ func (k Context) Oops(tags ...string) oops.OopsErrorBuilder

+ func (k Context) Pool() *pgxpool.Pool

+ func (k Context) Properties() Properties

+ func (k Context) RunTemplate(t gomplate.Template, env map[string]any) (string, error)

+ func (k Context) RunTemplateBool(t gomplate.Template, env map[string]any) (bool, error)

+ func (k Context) StartSpan(name string) (Context, trace.Span)

+ func (k Context) String() string

+ func (k Context) Subject() string

+ func (k Context) Topology() any

+ func (k Context) Transaction(fn func(ctx Context, span trace.Span) error, opts ...any) error

+ func (k Context) Verbose() logger.Logger

+ func (k Context) WithAnyValue(key, val any) Context

+ func (k Context) WithAppendObject(object any) Context

+ func (k Context) WithConnectionString(connectionString string) Context

+ func (k Context) WithDB(db *gorm.DB, pool *pgxpool.Pool) Context

+ func (k Context) WithDBLogLevel(level any) Context

+ func (k Context) WithDBLogger(name string, baseLevel any) Context

+ func (k Context) WithDeadline(deadline time.Time) (Context, gocontext.CancelFunc)

+ func (k Context) WithDebug() Context

+ func (k Context) WithKubernetes(conn KubernetesConnection) Context

+ func (k Context) WithLocalKubernetes(client *dutyKubernetes.Client) Context

+ func (k Context) WithLoggingValues(args ...interface{}) Context

+ func (k Context) WithName(name string) Context

+ func (k Context) WithNamespace(namespace string) Context

+ func (k Context) WithObject(object ...any) Context

+ func (k Context) WithSubject(subject string) Context

+ func (k Context) WithTimeout(timeout time.Duration) (Context, gocontext.CancelFunc)

+ func (k Context) WithTopology(topology any) Context

+ func (k Context) WithTrace() Context

+ func (k Context) WithValue(key, val any) Context

+ func (k Context) WithoutName() Context

+ func (k Context) WithoutTracing() Context

+ func (k Context) Wrap(ctx gocontext.Context) Context

+ func (k Context) WrapEcho(c echo.Context) Context

+ type ContextAccessor interface

+ Context func() map[string]any

+ type ContextAccessor2 interface

+ GetContext func() map[string]any

+ type Counter struct

+ Context Context

+ Counter *prometheus.CounterVec

+ Labels map[string]string

+ Name string

+ func (c *Counter) Label(k, v string) Counter

+ func (c Counter) Add(count int)

+ func (c Counter) AddFloat(count float64)

+ type EnvVarSourceBuilder struct

+ func (b *EnvVarSourceBuilder) GetString() (string, error)

+ func (b *EnvVarSourceBuilder) MustGetString() string

+ func (b *EnvVarSourceBuilder) WithConfigMapKeyRef(name, key string) *EnvVarSourceBuilder

+ func (b *EnvVarSourceBuilder) WithHelmRef(name, key string) *EnvVarSourceBuilder

+ func (b *EnvVarSourceBuilder) WithSecretKeyRef(name, key string) *EnvVarSourceBuilder

+ func (b *EnvVarSourceBuilder) WithServiceAccount(name string) *EnvVarSourceBuilder

+ type Gauge struct

+ Context Context

+ Gauge *prometheus.GaugeVec

+ Labels map[string]string

+ Name string

+ func (g Gauge) Add(count float64)

+ func (g Gauge) Set(count float64)

+ func (g Gauge) Sub(count float64)

+ type Gormable interface

+ DB func() *gorm.DB

+ type Histogram struct

+ Context Context

+ Histogram *prometheus.HistogramVec

+ Labels map[string]string

+ Name string

+ func (h *Histogram) Label(k, v string) Histogram

+ func (h Histogram) Record(duration time.Duration)

+ func (h Histogram) Since(s time.Time)

+ type KubernetesClient struct

+ Connection KubernetesConnection

+ func NewKubernetesClient(ctx Context, conn KubernetesConnection) (*KubernetesClient, error)

+ func (c *KubernetesClient) Refresh(ctx Context) (*rest.Config, error)

+ func (c *KubernetesClient) SetExpiry(def time.Duration)

+ func (c *KubernetesClient) SetLogger(log logger.Logger)

+ func (c KubernetesClient) HasExpired() bool

+ type KubernetesConnection interface

+ CanExpire func() bool

+ Hash func() string

+ Populate func(Context, bool) (kubernetes.Interface, *rest.Config, error)

+ String func() string

+ type LabelsAccessor interface

+ GetLabels func() map[string]string

+ type NameAccessor interface

+ GetName func() string

+ type NamespaceAccess interface

+ GetNamespace func() string

+ type PKAccessor interface

+ PK func() string

+ type Poolable interface

+ Pool func() *pgxpool.Pool

+ type Properties map[string]string

+ func (p Properties) Duration(key string, def time.Duration) time.Duration

+ func (p Properties) Int(key string, def int) int

+ func (p Properties) Off(key string, def bool) bool

+ func (p Properties) On(def bool, keys ...string) bool

+ func (p Properties) String(key string, def string) string

+ func (p Properties) SupportedProperties() map[string]PropertyType

+ type PropertyType struct

+ Default interface{}

+ Key string

+ Type string

+ Value interface{}