jrpctest

package

v0.4.10 Latest Latest Go to latest Published: Feb 22, 2024 License: Unlicense Imports: 21 Imported by: 0

Details

View Source

const (
	DirectionSend = TestDirection("send")
	DirectionRecv = TestDirection("recv")
)

View Source

var OriginalTestData = &TestData{}

func BenchExecutor(sm ServerMaker) func(t *testing.B, c BenchContext)

func NewRouter() *jmux2.Mux

func NewRouterWithMaxSize(size int) *jmux2.Mux

func NewServer() *server.Server

func RunBasicTestSuite(t *testing.T, args BasicTestSuiteArgs)

func TestExecutor(sm ServerMaker) func(t *testing.T, c TestContext)

type BasicTestSuiteArgs struct {
	ServerMaker ServerMaker
}

type BenchContext func(t *testing.B, server *server.Server, client jsonrpc.Conn)

type ClientMaker func() jsonrpc.Conn

type EchoArgs struct {
	S string
}

type EchoResult struct {
	String string
	Int    int
	Args   *EchoArgs
}

type FlakeyListener struct {
	net.Listener
	// contains filtered or unexported fields
}

flakeyListener kills accepted connections after a random timeout.

func (l *FlakeyListener) Accept() (net.Conn, error)

type LargeRespService struct {
	Length int
}

largeRespService generates arbitrary-size JSON responses.

func (x LargeRespService) LargeResp() string

type ServerMaker func() (*server.Server, ClientMaker, func())

type TestAction struct {
	Direction TestDirection
	Data      json.RawMessage
}

type TestContext func(t *testing.T, server *server.Server, client jsonrpc.Conn)

type TestData struct {
	Files []*TestFile
}

func (td *TestData) AddTestData(name string, rd io.Reader) *TestData

type TestDirection string

type TestFile struct {
	Name   string
	Action []*TestAction
}