Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncQueue ¶
type AsyncQueue[T any] interface { // Dequeue will pop the first available item off of the queue. // This function will block until there is an item available, or the context is canceled. // If the context is canceled this function will return ctx.Err(). Dequeue(ctx context.Context) (T, error) // Enqueue will push an item onto the queue. If no space is available on the queue, // this function will return immediately and drop the item. Enqueue(T) // Next will return a channel so that this can be used in a select statement. Next() <-chan T }
func NewAsyncQueue ¶
func NewAsyncQueue[T any]() AsyncQueue[T]
type DiscoveryInputs ¶
type DiscoveryInputs struct { Upstreams v1.UpstreamList Endpoints v1.EndpointList }
type ProxyXdsSyncer ¶
type ProxyXdsSyncer interface { ProyxSyncer SyncXdsOnEvent( ctx context.Context, onXdsSynced func(XdsSyncResult), ) }
type ProyxSyncer ¶
type ProyxSyncer interface { UpdateDiscoveryInputs(ctx context.Context, inputs DiscoveryInputs) UpdateSecretInputs(ctx context.Context, inputs SecretInputs) Kick(ctx context.Context) }
ProyxSyncer is the write interface where different translators can publish their outputs (which are the proxy syncer inputs)
type SecretInputs ¶
type SecretInputs struct {
Secrets v1.SecretList
}
type XdsInputChannels ¶
type XdsInputChannels struct {
// contains filtered or unexported fields
}
func NewXdsInputChannels ¶
func NewXdsInputChannels() *XdsInputChannels
func (*XdsInputChannels) Kick ¶
func (x *XdsInputChannels) Kick(ctx context.Context)
func (*XdsInputChannels) UpdateDiscoveryInputs ¶
func (x *XdsInputChannels) UpdateDiscoveryInputs(ctx context.Context, inputs DiscoveryInputs)
func (*XdsInputChannels) UpdateSecretInputs ¶
func (x *XdsInputChannels) UpdateSecretInputs(ctx context.Context, inputs SecretInputs)
type XdsSyncResult ¶
type XdsSyncResult struct {
ResourceReports reporter.ResourceReports
}
type XdsSyncer ¶
type XdsSyncer struct {
// contains filtered or unexported fields
}
func NewXdsSyncer ¶
func NewXdsSyncer( controllerName string, translator translator.Translator, sanitizer sanitizer.XdsSanitizer, xdsCache envoycache.SnapshotCache, xdsGarbageCollection bool, inputs *XdsInputChannels, cli client.Client, scheme *runtime.Scheme, ) *XdsSyncer
func (*XdsSyncer) ServeXdsSnapshots ¶
ServeXdsSnapshots exposes Gloo configuration as an API when `devMode` in Settings is True. TODO(ilackarms): move this somewhere else, make it part of dev-mode https://github.com/solo-io/gloo/issues/6494
Click to show internal directories.
Click to hide internal directories.