serverstats

type Event interface {
	// contains filtered or unexported methods
}

type Handler interface {
	HandleServerEvent(context.Context, Event)
}

type IRVMatchedResource struct {
	// The name of the resource
	ResourceName string
	// The resource itself, nil if the resource is being deleted.
	Resource *ads.RawResource
}

type RequestProcessed struct {
	// The received request, either [ads.SotWDiscoveryRequest] or [ads.DeltaDiscoveryRequest].
	Req proto.Message
	// The given duration represents the time it took to process its subscriptions (including any time
	// spent in the request limiter, if enabled). It does not include the time for any of the resources to
	// be sent in a response.
	Duration time.Duration
}

type RequestReceived struct {
	// The received request, either [ads.SotWDiscoveryRequest] or [ads.DeltaDiscoveryRequest].
	Req proto.Message
	// Whether the request is an ACK
	IsACK bool
	// Whether the request is a NACK. Note that this is an important stat that requires immediate human
	// intervention.
	IsNACK bool
	// If the request is an ACK or a NACK, it will include a nonce, which should correspond to a nonce
	// listed in a previously emitted [ResponseSent] event.
	Nonce string
}

type ResourceMarshalError struct {
	// The name of the resource that could not be marshaled.
	ResourceName string
	// The resource that could not be marshaled.
	Resource proto.Message
	// The marshaling error.
	Err error
}

type ResourceOverMaxSize struct {
	// The resource that could not be sent.
	Resource *ads.RawResource
	// The encoded resource size.
	ResourceSize int
	// The maximum resource size (usually 4MB, gRPC's default max message size).
	MaxResourceSize int
}

type ResponseSent struct {
	// The type URL of the resources in the response.
	TypeURL string
	// The resources that were sent.
	Resources map[string]SentResource
	// How long the Send operation took. This includes any time added by flow-control.
	Duration time.Duration
}

type SendingResponse struct {
	// The response that is about to be sent.
	Res proto.Message
	// The nonce used in the responses.
	Nonce string
}

type SentResource struct {
	// The resource itself, nil if the resource is being deleted.
	Resource *ads.RawResource
	// The metadata for the resource and subscription.
	Metadata ads.SubscriptionMetadata
	// The time at which the resource was queued to be sent. This means that it does not include any time
	// spent in the granular or global rate limiters, or sending the response, which can take an arbitrarily
	// long time due to flow control.
	QueuedAt time.Time
}

type TimeInGlobalRateLimiter struct {
	// How long the server waited for the global rate limiter to clear.
	Duration time.Duration
}

type UnknownResourceRequested struct {
	// The resource's type.
	TypeURL string
	// The resource's name.
	ResourceName string
}