dataplanetest

Sep 18, 2026

Changes in this version

type Fixture

+ func (f *Fixture) Conn() *grpc.ClientConn

+ func (f *Fixture) Gatherer() prometheus.Gatherer

+ type Option func(*options)

+ func WithAuth(a auth.Authenticator) Option

Sep 11, 2026

Changes in this version

type Upstream

+ func (u *Upstream) Listen() config.ListenConfig

Aug 13, 2026

Changes in this version

+ const DefaultUpstream

+ func Config(up *Upstream) *config.Config

+ func DeadUpstream(t *testing.T) string

+ func DialUnix(t *testing.T, path string) *grpc.ClientConn

+ type Fixture struct

+ func Start(t *testing.T, cfg *config.Config) *Fixture

+ func StartApp(t *testing.T, cfg *config.Config) *Fixture

+ func (f *Fixture) Addr() string

+ func (f *Fixture) Client() workflowservice.WorkflowServiceClient

+ func (f *Fixture) Context() context.Context

+ func (f *Fixture) UpstreamConn(name string) *grpc.ClientConn

+ type Upstream struct

+ func NewTLSUpstream(t *testing.T) *Upstream

+ func NewUpstream(t *testing.T) *Upstream

+ func (u *Upstream) Addr() string

+ func (u *Upstream) GetSystemInfo(ctx context.Context, req *workflowservice.GetSystemInfoRequest) (*workflowservice.GetSystemInfoResponse, error)

+ func (u *Upstream) Metadata() metadata.MD

+ func (u *Upstream) QueryWorkflow(ctx context.Context, req *workflowservice.QueryWorkflowRequest) (*workflowservice.QueryWorkflowResponse, error)

+ func (u *Upstream) Requests() []proto.Message

+ func (u *Upstream) TLSConfig() *config.TLSConfig