plugin

func (*Driver) Close ¶

func (d *Driver) Close() error

Close closes the gRPC connection

func (*Driver) Delete ¶

func (d *Driver) Delete(ctx context.Context, artifactRef *wfv1.Artifact) error

Delete implements ArtifactDriver.Delete by calling the plugin service

func (*Driver) IsDirectory ¶

func (d *Driver) IsDirectory(ctx context.Context, artifactRef *wfv1.Artifact) (bool, error)

IsDirectory implements ArtifactDriver.IsDirectory by calling the plugin service

func (*Driver) ListObjects ¶

func (d *Driver) ListObjects(ctx context.Context, artifactRef *wfv1.Artifact) ([]string, error)

ListObjects implements ArtifactDriver.ListObjects by calling the plugin service

func (*Driver) Load ¶

func (d *Driver) Load(ctx context.Context, inputArtifact *wfv1.Artifact, path string) error

Load implements ArtifactDriver.Load by calling the plugin service

func (*Driver) OpenStream ¶

func (d *Driver) OpenStream(ctx context.Context, a *wfv1.Artifact) (io.ReadCloser, error)

OpenStream implements ArtifactDriver.OpenStream by calling the plugin service

func (*Driver) Save ¶

func (d *Driver) Save(ctx context.Context, path string, outputArtifact *wfv1.Artifact) error

Save implements ArtifactDriver.Save by calling the plugin service

func (*Driver) SaveStream ¶

func (d *Driver) SaveStream(ctx context.Context, reader io.Reader, outputArtifact *wfv1.Artifact) error

SaveStream implements ArtifactDriver.SaveStream. If the plugin advertises streaming support (per GetCapabilities), the reader is streamed directly with no local buffering. Otherwise it falls back to buffering to a temp file and calling the existing unary Save, so a plugin that predates streaming keeps working.

Capability is checked before reader is touched: once GetCapabilities confirms streaming support and chunks start being sent, a mid-stream failure is returned as an error rather than retried via the fallback, since the reader may already be partially consumed and cannot be rewound.