cockroach: github.com/cockroachdb/cockroach/pkg/storage/closedts/transport/testutils Index | Files

package testutils

import "github.com/cockroachdb/cockroach/pkg/storage/closedts/transport/testutils"

Index

Package Files

chan_dialer.go

type ChanDialer Uses

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

ChanDialer is an implementation of closedts.Dialer that connects clients directly via a channel to a Server.

func NewChanDialer Uses

func NewChanDialer(stopper *stop.Stopper, server ctpb.Server) *ChanDialer

NewChanDialer sets up a ChanDialer.

func (*ChanDialer) Dial Uses

func (d *ChanDialer) Dial(ctx context.Context, nodeID roachpb.NodeID) (ctpb.Client, error)

Dial implements closedts.Dialer.

func (*ChanDialer) Ready Uses

func (d *ChanDialer) Ready(nodeID roachpb.NodeID) bool

Ready implements closedts.Dialer by always returning true.

func (*ChanDialer) Transcript Uses

func (d *ChanDialer) Transcript(nodeID roachpb.NodeID) []interface{}

Transcript returns a slice of messages sent over the "wire".

Package testutils imports 6 packages (graph). Updated 2019-08-17. Refresh now. Tools for package owners.