xdstest

Documentation

Index

• type XDSClient
  • func NewClient(xdsServer *XDSServer) (*XDSClient, error)
  • func (c *XDSClient) Cleanup()
• type XDSServer
  • func NewXdsServer(t *testing.T) *XDSServer
  • func (f *XDSServer) DeltaAggregatedResources(server discoveryv3.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
  • func (f *XDSServer) StreamAggregatedResources(server discoveryv3.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

Types

type XDSClient

type XDSClient struct {
	Client      discoveryv3.AggregatedDiscoveryServiceClient
	AdsClient   discoveryv3.AggregatedDiscoveryService_StreamAggregatedResourcesClient
	DeltaClient discoveryv3.AggregatedDiscoveryService_DeltaAggregatedResourcesClient
	// contains filtered or unexported fields
}

func NewClient

func NewClient(xdsServer *XDSServer) (*XDSClient, error)

func (*XDSClient) Cleanup

func (c *XDSClient) Cleanup()

type XDSServer

type XDSServer struct {
	Listener *bufconn.Listener

	DeltaResponses chan *discoveryv3.DeltaDiscoveryResponse
	// contains filtered or unexported fields
}

func NewXdsServer

func NewXdsServer(t *testing.T) *XDSServer

func (*XDSServer) DeltaAggregatedResources

func (f *XDSServer) DeltaAggregatedResources(server discoveryv3.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error

func (*XDSServer) StreamAggregatedResources

func (f *XDSServer) StreamAggregatedResources(server discoveryv3.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error