internal

package

v0.24.0 Latest Latest Go to latest Published: Sep 8, 2026 License: Apache-2.0 Imports: 12 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 ¶

Constants
func CheckSizeLimit(size int64, limit int64, kind string) error
func CopyDiscardLimited(r io.Reader, limit int64, kind string) error
func DecodeWSMessage(bytes []byte, msg proto.Message) error
func ReadAllLimited(r io.Reader, limit int64, kind string) ([]byte, error)
func ResolveMaxMessageSize(maxMessageSize int64) int64
func WriteWSMessage(conn *websocket.Conn, msg proto.Message, maxMessageSize int64) 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
type SizeLimitError
- func (e *SizeLimitError) Error() string

Constants ¶

View Source

const DefaultMaxMessageSize int64 = 64 * 1024 * 1024

Variables ¶

This section is empty.

Functions ¶

func CheckSizeLimit ¶ added in v0.24.0

func CheckSizeLimit(size int64, limit int64, kind string) error

func CopyDiscardLimited ¶ added in v0.24.0

func CopyDiscardLimited(r io.Reader, limit int64, kind string) error

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 ReadAllLimited ¶ added in v0.24.0

func ReadAllLimited(r io.Reader, limit int64, kind string) ([]byte, error)

func ResolveMaxMessageSize ¶ added in v0.24.0

func ResolveMaxMessageSize(maxMessageSize int64) int64

func WriteWSMessage ¶ added in v0.5.0

func WriteWSMessage(conn *websocket.Conn, msg proto.Message, maxMessageSize int64) 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.

type SizeLimitError ¶ added in v0.24.0

type SizeLimitError struct {
	Kind  string
	Limit int64
}

func (*SizeLimitError) Error ¶ added in v0.24.0

func (e *SizeLimitError) Error() string

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