plugin

package

v4.0.2 Latest Latest Go to latest Published: Mar 11, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Driver struct {
	// contains filtered or unexported fields
}

Driver implements the ArtifactDriver interface by making gRPC calls to a plugin service

func NewDriver(ctx context.Context, pluginName wfv1.ArtifactPluginName, socketPath string, connectionTimeout time.Duration) (*Driver, error)

NewDriver creates a new plugin artifact driver

func (d *Driver) Close() error

Close closes the gRPC connection

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

Delete implements ArtifactDriver.Delete by calling the plugin service

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

IsDirectory implements ArtifactDriver.IsDirectory by calling the plugin service

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

ListObjects implements ArtifactDriver.ListObjects by calling the plugin service

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

Load implements ArtifactDriver.Load by calling the plugin service

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

OpenStream implements ArtifactDriver.OpenStream by calling the plugin service

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

Save implements ArtifactDriver.Save by calling the plugin service