signedrequests

Documentation

Index

• Constants
• type Client
  • func NewClient(ctx context.Context, bucketConf *client.BucketConfig) (Client, error)
  • func NewPrefixedClient(client Client, prefix string) Client
• type ErrUnsupportedProvider
  • func (e ErrUnsupportedProvider) Error() string
• type GCSClient
  • func NewGCSBucketWithConfig(ctx context.Context, gc gcs.Config) (*GCSClient, error)
  • func NewGCSClient(ctx context.Context, conf []byte) (*GCSClient, error)
  • func (c *GCSClient) Close() error
  • func (c *GCSClient) SignedGET(ctx context.Context, objectKey string, expiry time.Time) (string, error)
  • func (c *GCSClient) SignedPUT(ctx context.Context, objectKey string, size int64, expiry time.Time) (string, error)
• type PrefixedClient
  • func (c *PrefixedClient) Close() error
  • func (c *PrefixedClient) SignedGET(ctx context.Context, objectKey string, expiry time.Time) (string, error)
  • func (c *PrefixedClient) SignedPUT(ctx context.Context, objectKey string, size int64, expiry time.Time) (string, error)

Constants

const DirDelim = "/"

DirDelim is the delimiter used to model a directory structure in an object store bucket.

Types

type Client

type Client interface {
	io.Closer
	SignedPUT(
		ctx context.Context,
		objectKey string,
		size int64,
		expiry time.Time,
	) (string, error)
	SignedGET(
		ctx context.Context,
		objectKey string,
		expiry time.Time,
	) (string, error)
}

func NewClient

func NewClient(ctx context.Context, bucketConf *client.BucketConfig) (Client, error)

func NewPrefixedClient

func NewPrefixedClient(client Client, prefix string) Client

type ErrUnsupportedProvider

type ErrUnsupportedProvider struct {
	Provider client.ObjProvider
}

func (ErrUnsupportedProvider) Error

func (e ErrUnsupportedProvider) Error() string

type GCSClient

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

func NewGCSBucketWithConfig

func NewGCSBucketWithConfig(ctx context.Context, gc gcs.Config) (*GCSClient, error)

func NewGCSClient

func NewGCSClient(ctx context.Context, conf []byte) (*GCSClient, error)

func (*GCSClient) Close

func (c *GCSClient) Close() error

func (*GCSClient) SignedGET

func (c *GCSClient) SignedGET(
	ctx context.Context,
	objectKey string,
	expiry time.Time,
) (string, error)

func (*GCSClient) SignedPUT

func (c *GCSClient) SignedPUT(
	ctx context.Context,
	objectKey string,
	size int64,
	expiry time.Time,
) (string, error)

type PrefixedClient

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

func (*PrefixedClient) Close

func (c *PrefixedClient) Close() error

func (*PrefixedClient) SignedGET

func (c *PrefixedClient) SignedGET(
	ctx context.Context,
	objectKey string,
	expiry time.Time,
) (string, error)

func (*PrefixedClient) SignedPUT

func (c *PrefixedClient) SignedPUT(
	ctx context.Context,
	objectKey string,
	size int64,
	expiry time.Time,
) (string, error)