client

Documentation

Index

• type Callbacks
• type DDSSyncClient
  • func NewDDSSyncClient(log logr.Logger, rt []core_model.ResourceType, ddsStream DeltaDDSStream, ...) DDSSyncClient
• type DDSSyncServiceStream
• type DeltaDDSStream
  • func NewDeltaDDSStream(s DDSSyncServiceStream, clientId string, runtimeInfo core_runtime.RuntimeInfo, ...) DeltaDDSStream
• type UpstreamResponse

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
}