GO-2025-4119: AWS Advanced Go Wrapper: Privilege Escalation in Aurora PostgreSQL Instance in github.com/aws/aws-advanced-go-wrapper/awssql

telemetry

package

v1.1.0 Latest Latest Go to latest Published: Oct 8, 2025 License: Apache-2.0 Imports: 5 Imported by: 7

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aws/aws-advanced-go-wrapper

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func UseTelemetryFactory(name string, factory TelemetryFactory)
type DefaultTelemetryFactory
- func NewDefaultTelemetryFactory(props *utils.RWMap[string, string]) (*DefaultTelemetryFactory, error)
type NilTelemetryContext
type NilTelemetryCounter
- func (n NilTelemetryCounter) Add(_ context.Context, _ int64)
- func (n NilTelemetryCounter) Inc(_ context.Context)
type NilTelemetryFactory
- func NewNilTelemetryFactory() *NilTelemetryFactory
type NilTelemetryGauge
type TelemetryContext
type TelemetryCounter
type TelemetryFactory
type TelemetryGauge
type TelemetryTraceLevel

Constants ¶

View Source

const (
	INSTRUMENTATION_NAME     = "aws-advanced-go-wrapper"
	TRACE_NAME_ANNOTATION    = "traceName"
	SOURCE_TRACE_ANNOTATION  = "sourceTraceId"
	PARENT_TRACE_ANNOTATION  = "parentTraceId"
	PARENT_SPAN_ANNOTATION   = "parentSpanId"
	ERROR_TYPE_ANNOTATION    = "errorType"
	ERROR_MESSAGE_ANNOTATION = "errorMessage"
	COPY_TRACE_NAME_PREFIX   = "copy: "

	TELEMETRY_OPEN_CONNECTION    = "Aws Advanced Go Wrapper - Open"
	TELEMETRY_EXECUTE            = "AWS Advanced Go Wrapper - %s"
	TELEMETRY_INIT_HOST_PROVIDER = "initHostProvider"
	TELEMETRY_CONNECT            = "connect"
	TELEMETRY_CONNECT_INTERNAL   = "%s - connect"
	TELEMETRY_FETCH_TOKEN        = "fetch authentication token"
	TELEMETRY_UPDATE_SECRETS     = "fetch credentials"
	TELEMETRY_CONN_STATUS_CHECK  = "connection status check"
	TELEMETRY_WRITER_FAILOVER    = "failover to writer host"
	TELEMETRY_READER_FAILOVER    = "failover to reader host"
	TELEMETRY_FETCH_SAML_ADFS    = "fetch ADFS SAML Assertion"
	TELEMETRY_FETCH_SAML_OKTA    = "fetch OKTA SAML Assertion"

	TELEMETRY_ATTRIBUTE_URL      = "url"
	TELEMETRY_ATTRIBUTE_SQL_CALL = "sqlCall"
)

Variables ¶

This section is empty.

Functions ¶

func UseTelemetryFactory ¶

func UseTelemetryFactory(name string, factory TelemetryFactory)

Types ¶

type DefaultTelemetryFactory ¶

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

func NewDefaultTelemetryFactory ¶

func NewDefaultTelemetryFactory(props *utils.RWMap[string, string]) (*DefaultTelemetryFactory, error)

func (*DefaultTelemetryFactory) CreateCounter ¶

func (d *DefaultTelemetryFactory) CreateCounter(name string) (TelemetryCounter, error)

func (*DefaultTelemetryFactory) CreateGauge ¶

func (d *DefaultTelemetryFactory) CreateGauge(name string) (TelemetryGauge, error)

func (*DefaultTelemetryFactory) OpenTelemetryContext ¶

func (d *DefaultTelemetryFactory) OpenTelemetryContext(name string, traceLevel TelemetryTraceLevel, ctx context.Context) (TelemetryContext, context.Context)

func (*DefaultTelemetryFactory) PostCopy ¶

func (d *DefaultTelemetryFactory) PostCopy(telemetryContext TelemetryContext, traceLevel TelemetryTraceLevel) error

type NilTelemetryContext ¶

type NilTelemetryContext struct {
}

func (NilTelemetryContext) CloseContext ¶

func (n NilTelemetryContext) CloseContext()

func (NilTelemetryContext) GetName ¶

func (n NilTelemetryContext) GetName() string

func (NilTelemetryContext) SetAttribute ¶

func (n NilTelemetryContext) SetAttribute(_ string, _ string)

func (NilTelemetryContext) SetError ¶

func (n NilTelemetryContext) SetError(_ error)

func (NilTelemetryContext) SetSuccess ¶

func (n NilTelemetryContext) SetSuccess(_ bool)

type NilTelemetryCounter ¶

type NilTelemetryCounter struct {
}

func (NilTelemetryCounter) Add ¶

func (n NilTelemetryCounter) Add(_ context.Context, _ int64)

func (NilTelemetryCounter) Inc ¶

func (n NilTelemetryCounter) Inc(_ context.Context)

type NilTelemetryFactory ¶

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

func NewNilTelemetryFactory ¶

func NewNilTelemetryFactory() *NilTelemetryFactory

func (NilTelemetryFactory) CreateCounter ¶

func (n NilTelemetryFactory) CreateCounter(_ string) (TelemetryCounter, error)

func (NilTelemetryFactory) CreateGauge ¶

func (n NilTelemetryFactory) CreateGauge(_ string) (TelemetryGauge, error)

func (NilTelemetryFactory) OpenTelemetryContext ¶

func (n NilTelemetryFactory) OpenTelemetryContext(_ string, _ TelemetryTraceLevel, ctx context.Context) (TelemetryContext, context.Context)

func (NilTelemetryFactory) PostCopy ¶

func (n NilTelemetryFactory) PostCopy(_ TelemetryContext, _ TelemetryTraceLevel) error

type NilTelemetryGauge ¶

type NilTelemetryGauge struct {
}

type TelemetryContext ¶

type TelemetryContext interface {
	SetSuccess(success bool)
	SetAttribute(key string, value string)
	SetError(err error)
	GetName() string
	CloseContext()
}

type TelemetryCounter ¶

type TelemetryCounter interface {
	Add(ctx context.Context, val int64)
	Inc(ctx context.Context)
}

type TelemetryFactory ¶

type TelemetryFactory interface {
	OpenTelemetryContext(name string, traceLevel TelemetryTraceLevel, ctx context.Context) (TelemetryContext, context.Context)
	PostCopy(telemetryContext TelemetryContext, traceLevel TelemetryTraceLevel) error
	CreateCounter(name string) (TelemetryCounter, error)
	CreateGauge(name string) (TelemetryGauge, error)
}

type TelemetryGauge ¶

type TelemetryGauge interface{}

type TelemetryTraceLevel ¶

type TelemetryTraceLevel string

const (
	FORCE_TOP_LEVEL TelemetryTraceLevel = "FORCE_TOP_LEVEL"
	TOP_LEVEL       TelemetryTraceLevel = "TOP_LEVEL"
	NESTED          TelemetryTraceLevel = "NESTED"
	NO_TRACE        TelemetryTraceLevel = "NO_TRACE"
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL