kss

type Configuration struct {
	DriverType         DriverType
	LocalConfiguration *LocalConfiguration
	S3Configuration    *S3Configuration
}

type Driver interface {
	GetPreSignedURL(method Method, key string, expireIn time.Duration) (URL string, err error)
	Delete(key string) error
	DeleteAllWithPrefix(key string) error
	WithCallBack(FileUpdatedCallBack)
	UploadData(key string, data []byte) error
	DownloadData(key string) ([]byte, error)
}

type DriverType string

type FileUpdatedCallBack func(event FileUpdatedEvent) error

type FileUpdatedEvent struct {
	Type  string
	Key   string
	Etags string
	Size  int64
}

type LocalConfiguration struct {
	KeyPrefix  string
	PublicURL  string
	PrivateKey *rsa.PrivateKey
}

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

type Method string

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

type S3Configuration struct {
	// AccessID is the ID to use when accessing the S3 bucket
	AccessID string

	// AccessKey is the Key to use when accessing the S3 bucket
	AccessKey string

	// The name of the bucket to use for storing files
	AWSBucketName string

	// The AWS region in which the bucket is located
	AWSRegion string

	// The prefix that will be added to add keys
	KeyPrefix string

	// SQSNotificationQueue defines the queue to listen to get event notification
	SQSNotificationQueue string
}

type S3Credentials struct {
	AccessID  string `env:"S3_ACCESS_ID" description:"the access ID to kss-test bucket"`
	AccessKey string `env:"S3_ACCESS_KEY" description:"the access ID to kss-test bucket"`
}