Documentation
¶
Index ¶
- func CombineCAs(ca *k8scorev1.Secret) []byte
- type Callbacks
- func (cb *Callbacks) OnDeltaStreamClosed(id int64)
- func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error
- func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error
- func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
- func (cb *Callbacks) OnStreamClosed(id int64)
- func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
- func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, ...)
- func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error
- func (cb *Callbacks) OnStreamRequest(int64, *discovery.DiscoveryRequest) error
- func (cb *Callbacks) OnStreamResponse(int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
- func (cb *Callbacks) Report()
- type EnvoyADS
- func (e *EnvoyADS) RunServer(ctx context.Context, log *logrus.Entry, server server.Server, port int)
- func (e *EnvoyADS) Start(ctx context.Context, port int, instance int64, debugEnvoy bool) error
- func (e *EnvoyADS) Sync() error
- func (e *EnvoyADS) SyncClusters(versionID string, clusters []*atlasCluster) error
- func (e *EnvoyADS) SyncObservability(versionID string, clusters []*atlasCluster) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CombineCAs ¶
Types ¶
type Callbacks ¶
type Callbacks struct {
Signal chan struct{}
Fetches int
Requests int
DeltaRequests int
DeltaResponses int
// contains filtered or unexported fields
}
func (*Callbacks) OnDeltaStreamClosed ¶
func (*Callbacks) OnDeltaStreamOpen ¶
func (*Callbacks) OnFetchRequest ¶
func (*Callbacks) OnFetchResponse ¶
func (cb *Callbacks) OnFetchResponse(*discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
func (*Callbacks) OnStreamClosed ¶
func (*Callbacks) OnStreamDeltaRequest ¶
func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
func (*Callbacks) OnStreamDeltaResponse ¶
func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, res *discovery.DeltaDiscoveryResponse)
func (*Callbacks) OnStreamOpen ¶
func (*Callbacks) OnStreamRequest ¶
func (cb *Callbacks) OnStreamRequest(int64, *discovery.DiscoveryRequest) error
func (*Callbacks) OnStreamResponse ¶
func (cb *Callbacks) OnStreamResponse(int64, *discovery.DiscoveryRequest, *discovery.DiscoveryResponse)
type EnvoyADS ¶
type EnvoyADS struct {
// contains filtered or unexported fields
}
func Register ¶
func Register( ctx context.Context, config *config.EnvoyADSConfig, log *logrus.Entry, apply apply.Apply, cliCtx *cli.Context, services wranglercorev1.ServiceController, secrets wranglercorev1.SecretController) *EnvoyADS
func (*EnvoyADS) RunServer ¶
func (e *EnvoyADS) RunServer(ctx context.Context, log *logrus.Entry, server server.Server, port int)
RunManagementServer starts an xDS server at the given port.
func (*EnvoyADS) SyncClusters ¶
func (*EnvoyADS) SyncObservability ¶
Source Files
Click to show internal directories.
Click to hide internal directories.