receiver

type Config struct {
	Sources    SourceLister
	Objects    ObjectWriter
	Bucket     string
	Recorder   Recorder
	RawWindows RawWindows
	Metrics    Metrics
	// Replica is this process's identity, the value of X-Platform-Instance.
	Replica string
	Logger  *slog.Logger
	// WriteTimeout bounds one segment write, including its retries by the
	// S3 client. A write that has not finished by then is answered 503.
	WriteTimeout time.Duration
	// Refresh is how often the source list is re-read, which is how a
	// change made on another replica reaches this one.
	Refresh    time.Duration
	StatsFlush time.Duration
	// RegisterRetry is how often a window whose raw partition could not be
	// registered is tried again.
	RegisterRetry time.Duration
	// MissRefresh is the least time between two re-reads of the sources made
	// for requests naming a source this replica does not serve.
	MissRefresh time.Duration
	// Spool, when set, is the receiver's local spool (#2121): a request is
	// answered once its events are synced to it, and drained to object
	// storage behind the answer. Nil answers once they are in object storage.
	Spool       Spool
	SpoolLimits SpoolLimits
	Now         func() time.Time
}

type Metrics interface {
	WebhookRequest(ctx context.Context, source, outcome string)
	WebhookEvents(ctx context.Context, source string, n int)
	WebhookSegmentWritten(ctx context.Context, source string)
	WebhookAck(ctx context.Context, source string, d time.Duration)
	// WebhookBuffer reports how many events a source holds in memory: those
	// waiting to be written and those in a write under way.
	WebhookBuffer(ctx context.Context, source string, events int)
	// WebhookSpool reports what the receiver's spool holds and how old its
	// oldest event waiting is (#2121).
	WebhookSpool(ctx context.Context, bytes, events int64, files int, oldestAge time.Duration)
	// WebhookSpoolDrained counts events drained from the spool to object
	// storage.
	WebhookSpoolDrained(ctx context.Context, source string, events int)
	// WebhookSpoolDrainFailed counts a drain of the spool that failed.
	WebhookSpoolDrainFailed(ctx context.Context, source string)
	// WebhookResponse counts a request by the status it was answered with,
	// WebhookWritten a segment's events and bytes written to object
	// storage, and WebhookAckStages an acknowledged delivery's wait in each
	// stage (#2150).
	WebhookResponse(ctx context.Context, source string, status int)
	WebhookWritten(ctx context.Context, source string, events, bytes int)
	WebhookAckStages(ctx context.Context, source string, buffer, mark, put time.Duration)
}

type ObjectWriter interface {
	PutObject(ctx context.Context, bucket, key string, data []byte, contentType string) error
}

type RawWindows interface {
	EnsureRawWindow(ctx context.Context, src whsource.Source, start time.Time) error
}

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

type Recorder interface {
	MarkSegment(ctx context.Context, source string, start time.Time, length time.Duration, bytes int64) error
	RecordCounts(ctx context.Context, counts []whstore.Count) error
	RecordRejections(ctx context.Context, rejections []whstore.Rejection) error
	RecordLatency(ctx context.Context, latencies []whstore.Latency) error
	// RecordSpool writes the receiver's spool state; called only when the
	// receiver has a spool.
	RecordSpool(ctx context.Context, st whstore.SpoolState) error
	// RecordReplicaMinutes adds the receiver's minutes: events accepted and
	// written, and what its spool held (#2150).
	RecordReplicaMinutes(ctx context.Context, minutes []whstore.ReplicaMinute) error
}

type SourceLister interface {
	List(ctx context.Context) ([]whsource.Source, error)
}

type Spool interface {
	Dir() string
	Append(source string, rec whspool.Record) (took time.Duration, err error)
	Active(source string) (whspool.Stats, bool)
	Seal(source string) error
	Sealed(source string) []whspool.Segment
	Sources() []string
	Read(seg whspool.Segment) ([]whspool.Record, error)
	Remove(seg whspool.Segment) error
	Stats() whspool.Stats
}

type SpoolLimits struct {
	MaxBytes int64
	MaxAge   time.Duration
}