objstore

Documentation

Index

• type ObjectStore
• type ReportManagerObjStore
  • func (rmc ReportManagerObjStore) BucketExists(ctx context.Context, bucketName string) (bool, error)
  • func (rmc ReportManagerObjStore) GetBucketLifecycle(ctx context.Context, bucketName string) (*lifecycle.Configuration, error)
  • func (rmc ReportManagerObjStore) GetObject(ctx context.Context, bucketName, objectName string, ...) (io.Reader, error)
  • func (rmc ReportManagerObjStore) MakeBucket(ctx context.Context, bucketName string, opts minio.MakeBucketOptions) (err error)
  • func (rmc ReportManagerObjStore) PresignedGetObject(ctx context.Context, bucketName string, objectName string, ...) (u *url.URL, err error)
  • func (rmc ReportManagerObjStore) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, ...) (info minio.UploadInfo, err error)
  • func (rmc ReportManagerObjStore) SetBucketLifecycle(ctx context.Context, bucketName string, config *lifecycle.Configuration) error
  • func (rmc ReportManagerObjStore) StatObject(ctx context.Context, bucketName string, objectName string, ...) (minio.ObjectInfo, error)

Types

type ObjectStore

type ObjectStore interface {
	PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64,
		opts minio.PutObjectOptions) (info minio.UploadInfo, err error)

	GetObject(ctx context.Context, bucketName, objectName string, opts minio.GetObjectOptions) (io.Reader, error)

	BucketExists(ctx context.Context, bucketName string) (bool, error)

	MakeBucket(ctx context.Context, bucketName string, opts minio.MakeBucketOptions) error

	PresignedGetObject(ctx context.Context, bucketName, objectName string, expires time.Duration, reqParams url.Values) (*url.URL, error)

	StatObject(ctx context.Context, bucketName string, objectName string, opts minio.GetObjectOptions) (minio.ObjectInfo, error)

	SetBucketLifecycle(ctx context.Context, bucketName string, config *lifecycle.Configuration) error

	GetBucketLifecycle(ctx context.Context, bucketName string) (*lifecycle.Configuration, error)
}

type ReportManagerObjStore

type ReportManagerObjStore struct {
	ObjStoreClient *minio.Client
}

func (ReportManagerObjStore) BucketExists

func (rmc ReportManagerObjStore) BucketExists(ctx context.Context, bucketName string) (bool, error)

func (ReportManagerObjStore) GetBucketLifecycle

func (rmc ReportManagerObjStore) GetBucketLifecycle(ctx context.Context, bucketName string) (*lifecycle.Configuration, error)

func (ReportManagerObjStore) GetObject

func (rmc ReportManagerObjStore) GetObject(ctx context.Context, bucketName, objectName string, opts minio.GetObjectOptions) (io.Reader, error)

func (ReportManagerObjStore) MakeBucket

func (rmc ReportManagerObjStore) MakeBucket(ctx context.Context, bucketName string, opts minio.MakeBucketOptions) (err error)

func (ReportManagerObjStore) PresignedGetObject

func (rmc ReportManagerObjStore) PresignedGetObject(ctx context.Context, bucketName string, objectName string, expires time.Duration, reqParams url.Values) (u *url.URL, err error)

func (ReportManagerObjStore) PutObject

func (rmc ReportManagerObjStore) PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64,
	opts minio.PutObjectOptions) (info minio.UploadInfo, err error)

func (ReportManagerObjStore) SetBucketLifecycle

func (rmc ReportManagerObjStore) SetBucketLifecycle(ctx context.Context, bucketName string, config *lifecycle.Configuration) error

func (ReportManagerObjStore) StatObject

func (rmc ReportManagerObjStore) StatObject(ctx context.Context, bucketName string, objectName string, opts minio.GetObjectOptions) (minio.ObjectInfo, error)