awss3

Documentation

Index

• Variables
• type ChartInfo
• type Storage
  • func New(session *session.Session) *Storage
  • func (s *Storage) Delete(ctx context.Context, uri string) error
  • func (s *Storage) Exists(ctx context.Context, uri string) (bool, error)
  • func (s *Storage) FetchRaw(ctx context.Context, uri string) ([]byte, error)
  • func (s *Storage) IndexExists(ctx context.Context, uri string) (bool, error)
  • func (s *Storage) PutChart(ctx context.Context, uri string, r io.Reader, chartMeta, acl string, ...) (string, error)
  • func (s *Storage) PutIndex(ctx context.Context, uri string, acl string, r io.Reader) error
  • func (s *Storage) Traverse(ctx context.Context, repoURI string) (<-chan ChartInfo, <-chan error)

Variables

var (
	// ErrBucketNotFound signals that a bucket was not found.
	ErrBucketNotFound = errors.New("bucket not found")

	// ErrObjectNotFound signals that an object was not found.
	ErrObjectNotFound = errors.New("object not found")
)

Types

type ChartInfo

type ChartInfo struct {
	Meta     helmutil.ChartMetadata
	Filename string
	Hash     string
}

ChartInfo contains info about particular chart.

type Storage

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

Storage provides an interface to work with AWS S3 objects by s3 protocol.

func New

func New(session *session.Session) *Storage

New returns a new Storage.

func (*Storage) Delete

func (s *Storage) Delete(ctx context.Context, uri string) error

Delete deletes the object by uri. uri must be in the form of s3 protocol: s3://bucket-name/key[...].

func (*Storage) Exists

func (s *Storage) Exists(ctx context.Context, uri string) (bool, error)

Exists returns true if an object exists in the storage.

func (*Storage) FetchRaw

func (s *Storage) FetchRaw(ctx context.Context, uri string) ([]byte, error)

FetchRaw downloads the object from URI and returns it in the form of byte slice. uri must be in the form of s3 protocol: s3://bucket-name/key[...].

func (*Storage) IndexExists

func (s *Storage) IndexExists(ctx context.Context, uri string) (bool, error)

IndexExists returns true if index file exists in the storage for repository with the provided uri. uri must be in the form of s3 protocol: s3://bucket-name/key[...].

func (*Storage) PutChart

func (s *Storage) PutChart(ctx context.Context, uri string, r io.Reader, chartMeta, acl string, chartDigest string, contentType string) (string, error)

PutChart puts the chart file to the storage. uri must be in the form of s3 protocol: s3://bucket-name/key[...].

func (*Storage) PutIndex

func (s *Storage) PutIndex(ctx context.Context, uri string, acl string, r io.Reader) error

PutIndex puts the index file to the storage. uri must be in the form of s3 protocol: s3://bucket-name/key[...].

func (*Storage) Traverse

func (s *Storage) Traverse(ctx context.Context, repoURI string) (<-chan ChartInfo, <-chan error)

Traverse traverses all charts in the repository.