implementations

Documentation

Index

• func NewAWSRemoteURL(config *aws.Config, presignDuration time.Duration) interfaces.RemoteURLInterface
• func NewGCPRemoteURL(signingPrincipal string, signDuration time.Duration) interfaces.RemoteURLInterface
• func NewNoopRemoteURL(remoteDataStoreClient storage.DataStore) interfaces.RemoteURLInterface
• type AWSRemoteURL
  • func (a *AWSRemoteURL) Get(ctx context.Context, uri string) (admin.UrlBlob, error)
• type AWSS3Object
• type GCPGCSObject
• type GCPRemoteURL
  • func (g *GCPRemoteURL) Get(ctx context.Context, uri string) (admin.UrlBlob, error)
• type NoopRemoteURL
  • func (n *NoopRemoteURL) Get(ctx context.Context, uri string) (admin.UrlBlob, error)

Functions

func NewAWSRemoteURL

func NewAWSRemoteURL(config *aws.Config, presignDuration time.Duration) interfaces.RemoteURLInterface

func NewGCPRemoteURL

func NewGCPRemoteURL(signingPrincipal string, signDuration time.Duration) interfaces.RemoteURLInterface

func NewNoopRemoteURL

func NewNoopRemoteURL(remoteDataStoreClient storage.DataStore) interfaces.RemoteURLInterface

Types

type AWSRemoteURL

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

AWS-specific implementation of RemoteURLInterface

func (*AWSRemoteURL) Get

func (a *AWSRemoteURL) Get(ctx context.Context, uri string) (admin.UrlBlob, error)

type AWSS3Object

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

type GCPGCSObject

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

type GCPRemoteURL

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

GCP-specific implementation of RemoteURLInterface

func (*GCPRemoteURL) Get

func (g *GCPRemoteURL) Get(ctx context.Context, uri string) (admin.UrlBlob, error)

type NoopRemoteURL

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

No-op implementation of a RemoteURLInterface

func (*NoopRemoteURL) Get

func (n *NoopRemoteURL) Get(ctx context.Context, uri string) (admin.UrlBlob, error)