testutils

package

v1.0.2 Latest Latest Go to latest Published: Oct 26, 2020 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

code.aliyun.com/yjkj.ink/grpc

Links

Open Source Insights

Documentation ¶

Overview ¶

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

Index ¶

Constants
Variables
type Channel
- func NewChannel() *Channel
- func NewChannelWithSize(bufSize int) *Channel

Constants ¶

View Source

const (
	// DefaultChanRecvTimeout is the default timeout for receive operations on the
	// underlying channel.
	DefaultChanRecvTimeout = 1 * time.Second
	// DefaultChanBufferSize is the default buffer size of the underlying channel.
	DefaultChanBufferSize = 1
)

Variables ¶

View Source

var ErrRecvTimeout = errors.New("timed out when waiting for value on channel")

ErrRecvTimeout is an error to indicate that a receive operation on the channel timed out.

Functions ¶

This section is empty.

Types ¶

type Channel ¶

type Channel struct {
	// contains filtered or unexported fields
}

Channel wraps a generic channel and provides a timed receive operation.

func NewChannel ¶

func NewChannel() *Channel

NewChannel returns a new Channel.

func NewChannelWithSize ¶

func NewChannelWithSize(bufSize int) *Channel

NewChannelWithSize returns a new Channel with a buffer of bufSize.

func (*Channel) Receive ¶

func (cwt *Channel) Receive() (interface{}, error)

Receive returns the value received on the underlying channel, or ErrRecvTimeout if DefaultChanRecvTimeout amount of time elapses.

func (*Channel) Send ¶

func (cwt *Channel) Send(value interface{})

Send sends value on the underlying channel.

func (*Channel) TimedReceive ¶

func (cwt *Channel) TimedReceive(timeout time.Duration) (interface{}, error)

TimedReceive returns the value received on the underlying channel, or ErrRecvTimeout if timeout amount of time elapsed.

Source Files ¶

View all Source files

channel.go

Directories ¶

Path	Synopsis
fakeclient Package fakeclient provides a fake implementation of an xDS client.	Package fakeclient provides a fake implementation of an xDS client.
fakeserver Package fakeserver provides a fake implementation of an xDS server.	Package fakeserver provides a fake implementation of an xDS server.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL