client

Documentation

Index

• func NewKDSSink(log logr.Logger, clusterName string, rt []model.ResourceType, ...) component.Component
• type Callbacks
• type ClientFactory
• type KDSClient
  • func New(serverURL string, config *kds_config.KdsClientConfig) (KDSClient, error)
• type KDSStream
  • func NewKDSStream(s mesh_proto.KumaDiscoveryService_StreamKumaResourcesClient, clientId string) KDSStream

Functions

func NewKDSSink

func NewKDSSink(log logr.Logger, clusterName string, rt []model.ResourceType, factory ClientFactory, cb *Callbacks) component.Component

Types

type Callbacks

type Callbacks struct {
	OnResourcesReceived func(clusterID string, rs model.ResourceList) error
}

type ClientFactory

type ClientFactory func() (KDSClient, error)

type KDSClient

type KDSClient interface {
	StartStream(clientId string) (KDSStream, error)
	Close() error
}

func New

func New(serverURL string, config *kds_config.KdsClientConfig) (KDSClient, error)

type KDSStream

type KDSStream interface {
	DiscoveryRequest(resourceType model.ResourceType) error
	Receive() (string, model.ResourceList, error)
	ACK(typ string) error
	NACK(typ string, err error) error
	Close() error
}

func NewKDSStream

func NewKDSStream(s mesh_proto.KumaDiscoveryService_StreamKumaResourcesClient, clientId string) KDSStream