stream

type Aggregator func(reply any, msg *streamv1.BroadcastReplyList) error

type GatewayStreamApiExtensionPluginOption func(*GatewayStreamApiExtensionPluginOptions)

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

type GatewayStreamMetricsConfig struct {
	// Prometheus registerer
	Reader metric.Reader

	// A function called on each stream's Connect that returns a list of static
	// labels to attach to all metrics collected for that stream.
	LabelsForStream func(context.Context) []attribute.KeyValue
}

type Server struct {
	Desc              *grpc.ServiceDesc
	Impl              interface{}
	RequireCapability string
}

type StreamAPIExtension interface {
	StreamServers() []Server
}

type StreamAPIExtensionWithHandlers interface {
	StreamAPIExtension
	StreamClientHandler
}

type StreamClientHandler interface {
	UseStreamClient(client grpc.ClientConnInterface)
}

type StreamDelegate[T any] interface {
	WithTarget(*corev1.Reference) T
	WithBroadcastSelector(*corev1.ClusterSelector, Aggregator) T
}