Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Callbacks ¶
type Callbacks struct {
OnResourcesReceived func(upstream UpstreamResponse) error
}
type DDSSyncClient ¶
type DDSSyncClient interface {
Receive() error
}
func NewDDSSyncClient ¶
func NewDDSSyncClient( log logr.Logger, rt []core_model.ResourceType, ddsStream DeltaDDSStream, cb *Callbacks, responseBackoff time.Duration, ) DDSSyncClient
type DDSSyncServiceStream ¶
type DDSSyncServiceStream interface {
Send(*envoy_sd.DeltaDiscoveryRequest) error
Recv() (*envoy_sd.DeltaDiscoveryResponse, error)
}
type DeltaDDSStream ¶
type DeltaDDSStream interface {
DeltaDiscoveryRequest(resourceType model.ResourceType) error
Receive() (UpstreamResponse, error)
ACK(resourceType model.ResourceType) error
NACK(resourceType model.ResourceType, err error) error
}
All methods other than Receive() are non-blocking. It does not wait until the peer CP receives the message.
func NewDeltaDDSStream ¶
func NewDeltaDDSStream(s DDSSyncServiceStream, clientId string, runtimeInfo core_runtime.RuntimeInfo, cpConfig string) DeltaDDSStream
type UpstreamResponse ¶
type UpstreamResponse struct {
ControlPlaneId string
Type model.ResourceType
AddedResources model.ResourceList
RemovedResourcesKey []model.ResourceKey
IsInitialRequest bool
}
Source Files
Click to show internal directories.
Click to hide internal directories.