testpeer

package
v0.3.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package testpeer supplies real control transports around a scripted executor for integration tests. The scripts choose application responses; negotiation, metadata, admission and transport lifetime remain production implementations.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Control 

type Control struct {
	Client *erpc.BidiClient
	// contains filtered or unexported fields
}

Control owns separate loopback direct and reverse listeners and one actual executor client. Startup readiness is deliberately observed by the caller with its separate registration deadline.

func Start 

func Start(ctx context.Context, bidi *drpc.BidiServer, service pb.ExecutorServiceServer) (*Control, error)

func (*Control) Stop 

func (p *Control) Stop(ctx context.Context) error

Stop retains the real join even when a caller's cleanup deadline expires. A later invocation joins that same shutdown; a timed-out wait is not cleanup.

type ExecutorState 

type ExecutorState struct{ Service pb.ExecutorServiceServer }

func (ExecutorState) OnAbort 

func (s ExecutorState) OnAbort(ctx context.Context, _ controlsession.Binding, r *pb.AbortRequest) (*pb.AbortResponse, error)

func (ExecutorState) OnBandwidth 

func (s ExecutorState) OnBandwidth(ctx context.Context, _ controlsession.Binding, r *pb.BandwidthRequest) (*pb.BandwidthResponse, error)

func (ExecutorState) OnHello 

func (s ExecutorState) OnHello(ctx context.Context, r *pb.HelloRequest) (*pb.HelloResponse, error)

func (ExecutorState) OnInspectRetainedRun added in v0.3.0 

func (s ExecutorState) OnInspectRetainedRun(ctx context.Context, _ controlsession.Binding, r *pb.InspectRetainedRunRequest) (*pb.InspectRetainedRunResponse, error)

func (ExecutorState) OnUpload 

func (s ExecutorState) OnUpload(ctx context.Context, _ controlsession.Binding, r *pb.UploadRequest) (*pb.UploadResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.