client

Documentation

Index

• type Callbacks
• type KDSSink
  • func NewKDSSink(log logr.Logger, rt []model.ResourceType, kdsStream KDSStream, cb *Callbacks) KDSSink
• type KDSStream
  • func NewKDSStream(s mesh_proto.KumaDiscoveryService_StreamKumaResourcesClient, clientId string, ...) KDSStream

Types

type Callbacks

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

type KDSSink

type KDSSink interface {
	Receive() error
}

func NewKDSSink

func NewKDSSink(log logr.Logger, rt []model.ResourceType, kdsStream KDSStream, cb *Callbacks) KDSSink

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
}

func NewKDSStream

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