http

package

v4.1.0-rc1 Latest Latest Go to latest Published: Jul 23, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/argoproj/argo-workflows

Links

Open Source Insights

Documentation ¶

Index ¶

func CreateClientWithCertificate(clientCert, clientKey []byte) (*http.Client, error)
func CreateOauth2Client(ctx context.Context, clientID, clientSecret, tokenURL string, scopes []string, ...) *http.Client
type ArtifactDriver

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CreateClientWithCertificate ¶

func CreateClientWithCertificate(clientCert, clientKey []byte) (*http.Client, error)

func CreateOauth2Client ¶

func CreateOauth2Client(ctx context.Context, clientID, clientSecret, tokenURL string, scopes []string, endpointParams []wfv1.OAuth2EndpointParam) *http.Client

Types ¶

type ArtifactDriver ¶

type ArtifactDriver struct {
	Username string
	Password string
	Client   *http.Client
}

ArtifactDriver is the artifact driver for artifactory and http URLs

func (*ArtifactDriver) Delete ¶

func (h *ArtifactDriver) Delete(ctx context.Context, s *wfv1.Artifact) error

Delete is unsupported for the http artifacts

func (*ArtifactDriver) IsDirectory ¶

func (h *ArtifactDriver) IsDirectory(ctx context.Context, artifact *wfv1.Artifact) (bool, error)

func (*ArtifactDriver) ListObjects ¶

func (h *ArtifactDriver) ListObjects(ctx context.Context, artifact *wfv1.Artifact) ([]string, error)

func (*ArtifactDriver) Load ¶

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

Load reads the artifact from the HTTP URL

func (*ArtifactDriver) OpenStream ¶

func (h *ArtifactDriver) OpenStream(ctx context.Context, inputArtifact *wfv1.Artifact) (io.ReadCloser, error)

func (*ArtifactDriver) Save ¶

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

Save writes the artifact to the URL

func (*ArtifactDriver) SaveStream ¶

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

SaveStream saves an artifact from an io.Reader to HTTP URL

By default req.GetBody is not set: reader is a one-shot io.Reader that cannot be reopened, so a 307/308 redirect (e.g. webHDFS) cannot be followed with a re-sent body and surfaces as a request error. Destinations that need redirect support can set HTTP.SaveStreamViaFile to buffer the stream to a temp file and delegate to Save, which sets GetBody.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL