blob

Documentation

Index

• Variables
• type BlobStore
  • func NewBlobStorage(cfg *config.KubehoundConfig, blobConfig *config.BlobConfig) (*BlobStore, error)
  • func (bs *BlobStore) Close(ctx context.Context, archivePath string) error
  • func (bs *BlobStore) Extract(ctx context.Context, archivePath string) error
  • func (bs *BlobStore) ListFiles(ctx context.Context, prefix string, recursive bool) ([]*puller.ListObject, error)
  • func (bs *BlobStore) Pull(outer context.Context, key string) (string, error)
  • func (bs *BlobStore) Put(outer context.Context, archivePath string, clusterName string, runID string) error

Variables

var (
	ErrInvalidBucketName = errors.New("empty bucket name")
)

Types

type BlobStore

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

func NewBlobStorage

func NewBlobStorage(cfg *config.KubehoundConfig, blobConfig *config.BlobConfig) (*BlobStore, error)

func (*BlobStore) Close

func (bs *BlobStore) Close(ctx context.Context, archivePath string) error

Once downloaded and processed, we should cleanup the disk so we can reduce the disk usage required for large infrastructure

func (*BlobStore) Extract

func (bs *BlobStore) Extract(ctx context.Context, archivePath string) error

func (*BlobStore) ListFiles

func (bs *BlobStore) ListFiles(ctx context.Context, prefix string, recursive bool) ([]*puller.ListObject, error)

func (*BlobStore) Pull

func (bs *BlobStore) Pull(outer context.Context, key string) (string, error)

Pull pulls the data from the blob store (e.g: s3) and returns the path of the folder containing the archive

func (*BlobStore) Put

func (bs *BlobStore) Put(outer context.Context, archivePath string, clusterName string, runID string) error

Pull pulls the data from the blob store (e.g: s3) and returns the path of the folder containing the archive