Skip to main content

internal/domain/observationlimits.go

internal/domain · 28 lines · 3 declarations · source

Declarations​

const MaxObservationMessages, MaxMessageBytes, MaxObservationBytes​

const (
	MaxObservationMessages = 64
	MaxMessageBytes        = 64 << 10
	MaxObservationBytes    = 256 << 10
)

These bound a single append and its downstream extraction work. Durable backlog admission is separate: a bounded turn alone cannot prevent an unlimited number of turns during an outage.

source

var ErrMessageCount, ErrMessageSize, ErrObservationSize​

var (
	ErrMessageCount    = errors.New("observation exceeds 64 messages")
	ErrMessageSize     = errors.New("message exceeds 65536 UTF-8 bytes")
	ErrObservationSize = errors.New("observation content exceeds 262144 UTF-8 bytes")
)

source

func ValidateMessageCount​

func ValidateMessageCount(count int) error

ValidateMessageCount runs before allocating per-message validation or transport copies.

source