testutils

Documentation

Overview

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.