util

package

v0.43.0 Latest Latest Go to latest Published: Feb 24, 2026 License: MIT Imports: 6 Imported by: 0

Details

View Source

const MaxDrainResponseBytes = 16 << 10

MaxDrainResponseBytes is the maximum number of bytes that transport implementations will read from response bodies when draining them.

This section is empty.

func EnvelopeIdentifier(envelope *protocol.Envelope) string

EnvelopeIdentifier returns a human-readable identifier for the event to be used in log messages. Format: "<description> [<event-id>]".

func HandleHTTPResponse(response *http.Response, identifier string) bool

HandleHTTPResponse is a helper method that reads the HTTP response and handles debug output.

type SyncMap[K comparable, V any] struct {
	// contains filtered or unexported fields
}

func (s *SyncMap[K, V]) Clear()

func (s *SyncMap[K, V]) CompareAndDelete(key K, value V)

func (s *SyncMap[K, V]) Delete(key K)

func (s *SyncMap[K, V]) Load(key K) (V, bool)

func (s *SyncMap[K, V]) LoadOrStore(key K, value V) (V, bool)

func (s *SyncMap[K, V]) Range(f func(key K, value V) bool)

func (s *SyncMap[K, V]) Store(key K, value V)