internal

package

v0.23.0 Latest Latest Go to latest Published: Feb 18, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

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

Repository

github.com/open-telemetry/opamp-go

Links

Documentation ¶

Index ¶

func DecodeWSMessage(bytes []byte, msg proto.Message) error
func WriteWSMessage(conn *websocket.Conn, msg proto.Message) error
type NopLogger
- func (l *NopLogger) Debugf(ctx context.Context, format string, v ...interface{})
- func (l *NopLogger) Errorf(ctx context.Context, format string, v ...interface{})
type OptionalDuration
- func ExtractRetryAfterHeader(resp *http.Response) OptionalDuration

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DecodeWSMessage ¶ added in v0.5.0

func DecodeWSMessage(bytes []byte, msg proto.Message) error

DecodeWSMessage decodes a websocket message as bytes into a proto.Message.

func WriteWSMessage ¶ added in v0.5.0

func WriteWSMessage(conn *websocket.Conn, msg proto.Message) error

Types ¶

type NopLogger ¶

type NopLogger struct{}

func (*NopLogger) Debugf ¶

func (l *NopLogger) Debugf(ctx context.Context, format string, v ...interface{})

func (*NopLogger) Errorf ¶

func (l *NopLogger) Errorf(ctx context.Context, format string, v ...interface{})

type OptionalDuration ¶

type OptionalDuration struct {
	Duration time.Duration
	// true if duration field is defined.
	Defined bool
}

func ExtractRetryAfterHeader ¶

func ExtractRetryAfterHeader(resp *http.Response) OptionalDuration

ExtractRetryAfterHeader extracts Retry-After response header if the status is 503 or 429. Returns 0 duration if the header is not found or the status is different.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
examples module
testhelpers
tools module

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