relaytest

package
v1.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 30, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HostFunc added in v1.2.2

func HostFunc(fn func(relay.CallFrame, *relay.Conn) (string, error)) tchannel.RelayHost

HostFunc wraps a given function to implement tchannel.RelayHost.

Types

type FluentMockCallStats

type FluentMockCallStats struct {
	*MockCallStats
}

FluentMockCallStats wraps the MockCallStats in a fluent API that's convenient for tests.

func (*FluentMockCallStats) Failed

func (f *FluentMockCallStats) Failed(reason string) *FluentMockCallStats

Failed marks the RPC as failed.

func (*FluentMockCallStats) Succeeded

func (f *FluentMockCallStats) Succeeded() *FluentMockCallStats

Succeeded marks the RPC as succeeded.

type MockCallStats

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

MockCallStats is a testing spy for the CallStats interface.

func (*MockCallStats) End

func (m *MockCallStats) End()

End halts timer and metric collection for the RPC.

func (*MockCallStats) Failed

func (m *MockCallStats) Failed(reason string)

Failed marks the RPC as failed for the provided reason.

func (*MockCallStats) Succeeded

func (m *MockCallStats) Succeeded()

Succeeded marks the RPC as succeeded.

type MockStats

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

MockStats is a testing spy for the Stats interface.

func NewMockStats

func NewMockStats() *MockStats

NewMockStats constructs a MockStats.

func (*MockStats) Add

func (m *MockStats) Add(caller, callee, procedure string) *FluentMockCallStats

Add explicitly adds a new call along an edge of the call graph.

func (*MockStats) AssertEqual

func (m *MockStats) AssertEqual(t testing.TB, expected *MockStats)

AssertEqual asserts that two MockStats describe the same call graph.

func (*MockStats) Begin

func (m *MockStats) Begin(f relay.CallFrame) *MockCallStats

Begin starts collecting metrics for an RPC.

func (*MockStats) Map added in v1.14.0

func (m *MockStats) Map() map[string]int

Map returns all stats as a map of key to int.

func (*MockStats) WaitForEnd added in v1.14.0

func (m *MockStats) WaitForEnd()

WaitForEnd waits for all calls to End.

type StubRelayHost added in v1.2.2

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

StubRelayHost is a stub RelayHost for tests that backs peer selection to an underlying channel using isolated subchannels and the default peer selection.

func NewStubRelayHost added in v1.2.2

func NewStubRelayHost() *StubRelayHost

NewStubRelayHost creates a new stub RelayHost for tests.

func (*StubRelayHost) Add added in v1.2.2

func (rh *StubRelayHost) Add(service, hostPort string)

Add adds a service instance with the specified host:port.

func (*StubRelayHost) SetChannel added in v1.2.2

func (rh *StubRelayHost) SetChannel(ch *tchannel.Channel)

SetChannel is called by the channel after creation so we can get a reference to the channels' peers.

func (*StubRelayHost) Start added in v1.2.2

func (rh *StubRelayHost) Start(cf relay.CallFrame, _ *relay.Conn) (tchannel.RelayCall, error)

Start starts a new RelayCall for the given call on a specific connection.

func (*StubRelayHost) Stats added in v1.2.2

func (rh *StubRelayHost) Stats() *MockStats

Stats returns the *MockStats tracked for this channel.

Jump to

Keyboard shortcuts

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