blob

type Batch []*Object

type BatchRunner interface {
	Run(ctx context.Context) error
}

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

type BatchRunnerSettings struct {
	ClientName        string `cfg:"client_name" default:"default"`
	CopyRunnerCount   int    `cfg:"copy_runner_count" default:"10"`
	DeleteRunnerCount int    `cfg:"delete_runner_count" default:"10"`
	ReaderRunnerCount int    `cfg:"reader_runner_count" default:"10"`
	WriterRunnerCount int    `cfg:"writer_runner_count" default:"10"`
}

type BlobFixture struct{}

type CopyBatch []*CopyObject

type CopyObject struct {
	ACL types.ObjectCannedACL

	ContentEncoding *string
	ContentType     *string

	Error error

	Key *string

	SourceBucket *string
	SourceKey    *string
	// contains filtered or unexported fields
}

type DataExporter interface {
	ExportAllObjects(ctx context.Context) (StoreEntries, error)
}

type FixtureReader interface {
	Chan() <-chan *Object
	Run(ctx context.Context) error
	Stop()
	Source() string
}

type LifecycleManager interface {
	reslife.LifeCycleer
	reslife.Creator
	reslife.Registerer
	reslife.Purger
}

type Metadata struct {
	AwsClientName string `json:"aws_client_name"`
	Bucket        string `json:"bucket"`
	Name          string `json:"name"`
	Prefix        string `json:"prefix"`
}

type NamingFactory func() string

type Object struct {
	ACL  types.ObjectCannedACL
	Body Stream

	Bucket *string

	ContentEncoding *string
	ContentType     *string

	Error error

	Exists bool
	Key    *string
	Prefix *string
	// contains filtered or unexported fields
}

type ReadCloser interface {
	io.ReadCloser
}

type ReadSeekerCloser interface {
	io.ReadSeeker
	io.Closer
}

type ReaderFactory func(ctx context.Context, config cfg.Config, logger log.Logger, storeName string) (FixtureReader, error)

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

type Settings struct {
	cfg.AppId
	Bucket     string `cfg:"bucket"`
	Region     string `cfg:"region"`
	ClientName string `cfg:"client_name" default:"default"`
	Prefix     string `cfg:"prefix"`
}

type Store interface {
	BucketName() string
	Copy(batch CopyBatch)
	CopyOne(obj *CopyObject) error
	Delete(batch Batch)
	DeletePrefix(ctx context.Context, prefix string) error
	DeleteBucket(ctx context.Context) error
	DeleteOne(obj *Object) error
	ListObjects(ctx context.Context, prefix string) (Batch, error)
	Read(batch Batch)
	ReadOne(obj *Object) error
	Write(batch Batch) error
	WriteOne(obj *Object) error
}

type StoreEntries []StoreEntry

type StoreEntry struct {
	Key  string `json:"key"`
	Body []byte `json:"body"`
}

type StoreProviderFn func(storeName string) (Store, error)

type Stream interface {
	// Read all data and close the reader.
	ReadAll() ([]byte, error)
	// Extract a reader you have to close yourself. Calling this multiple times might return
	// the same object.
	AsReader() ReadSeekerCloser
}

type UrlBuilder interface {
	GetAbsoluteUrl(path string) (string, error)
}