Versions in this module Expand all Collapse all v1 v1.2.0 Oct 7, 2026 v1.1.0 Oct 7, 2026 v1.0.0 Oct 7, 2026 Changes in this version + const MaxValuesBytes + const PluginKey + const TargetKeyword + var Handshake = plugin.HandshakeConfig + var NameRe = regexp.MustCompile(`^[a-z][a-z0-9-]{0,62}$`) + var StepNameRe = regexp.MustCompile(`^[A-Za-z][A-Za-z0-9_-]{0,62}$`) + func CompileSchema(step string, schema []byte) (*jsonschema.Schema, error) + func Fail(class string, err error) error + func Failf(class, format string, args ...any) error + func NewServer(p *Plugin) (pluginv1.PluginServiceServer, error) + func Serve(p *Plugin) + func TargetFields(schema []byte) ([]string, error) + func ValidateConfig(s *jsonschema.Schema, config []byte) error + func ValidateDescription(d *pluginv1.DescribeResponse) error + type Call struct + Baggage string + Config json.RawMessage + Iteration int64 + Session any + Step string + Timeout time.Duration + Traceparent string + VU int64 + func (c *Call) Decode(v any) error + type Error struct + Class string + Err error + func (e *Error) Error() string + func (e *Error) Unwrap() error + type GRPCPlugin struct + Impl pluginv1.PluginServiceServer + func (p *GRPCPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (any, error) + func (p *GRPCPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error + type Phases struct + Connect time.Duration + DNS time.Duration + Download time.Duration + FirstEvent time.Duration + TLS time.Duration + Wait time.Duration + type Plugin struct + Description string + Name string + NewSession func(ctx context.Context, info SessionInfo) (any, error) + Steps []Step + Version string + type Result struct + BytesIn int64 + BytesOut int64 + Events int64 + Latency time.Duration + Phases Phases + Skipped bool + Values any + type SessionInfo struct + RunID string + VU int64 + type Step struct + Description string + Name string + Run func(ctx context.Context, c *Call) (*Result, error) + Schema string