package testutils

import "google.golang.org/grpc/xds/internal/testutils"

Package testutils provides utility types, for use in xds tests.

Index ¶

• func BuildResourceName(typeName, auth, id string, ctxParams map[string]string) string
• type TestResourceWatcher
• func NewTestResourceWatcher() *TestResourceWatcher
• func (w *TestResourceWatcher) OnError(err error, onDone xdsresource.OnDoneFunc)
• func (w *TestResourceWatcher) OnResourceDoesNotExist(onDone xdsresource.OnDoneFunc)
• func (w *TestResourceWatcher) OnUpdate(data xdsresource.ResourceData, onDone xdsresource.OnDoneFunc)

Functions ¶

func BuildResourceName ¶

func BuildResourceName(typeName, auth, id string, ctxParams map[string]string) string

BuildResourceName returns the resource name in the format of an xdstp:// resource.

Types ¶

type TestResourceWatcher ¶

type TestResourceWatcher struct {
	// UpdateCh is the channel on which xDS client updates are delivered.
	UpdateCh chan *xdsresource.ResourceData
	// ErrorCh is the channel on which errors from the xDS client are delivered.
	ErrorCh chan error
	// ResourceDoesNotExistCh is the channel used to indicate calls to OnResourceDoesNotExist
	ResourceDoesNotExistCh chan struct{}
}

TestResourceWatcher implements the xdsresource.ResourceWatcher interface, used to receive updates on watches registered with the xDS client, when using the resource-type agnostic WatchResource API.

Tests can use the channels provided by this type to get access to updates and errors sent by the xDS client.

func NewTestResourceWatcher ¶

func NewTestResourceWatcher() *TestResourceWatcher

NewTestResourceWatcher returns a TestResourceWatcher to watch for resources via the xDS client.

func (*TestResourceWatcher) OnError ¶

func (w *TestResourceWatcher) OnError(err error, onDone xdsresource.OnDoneFunc)

OnError is invoked by the xDS client to report the latest error.

func (*TestResourceWatcher) OnResourceDoesNotExist ¶

func (w *TestResourceWatcher) OnResourceDoesNotExist(onDone xdsresource.OnDoneFunc)

OnResourceDoesNotExist is used by the xDS client to report that the resource being watched no longer exists.

func (*TestResourceWatcher) OnUpdate ¶

func (w *TestResourceWatcher) OnUpdate(data xdsresource.ResourceData, onDone xdsresource.OnDoneFunc)

OnUpdate is invoked by the xDS client to report the latest update on the resource being watched.

Source Files ¶

resource_watcher.go testutils.go

Directories ¶