minio

Documentation

Index

• func NewMinIOClient(cfg config.Config) (*minio.Client, error)
• type EncodedObjectClient
  • func NewEncodedObjectClient(bucketName config.EncodedObjectBucketName, client *minio.Client) *EncodedObjectClient
  • func (m *EncodedObjectClient) GetObject(ctx context.Context, mediaID string, fileName string) (io.ReadSeekCloser, error)
  • func (m *EncodedObjectClient) Upload(ctx context.Context, mediaID string, localDir string) error
• type SourceClient
  • func NewSourceClient(bucketName config.SourceClientBucketName, client *minio.Client) *SourceClient
  • func (m *SourceClient) DeleteSourceContent(ctx context.Context, id string) error
  • func (m *SourceClient) GetSourceContent(ctx context.Context, id string) (io.ReadSeekCloser, error)
  • func (m *SourceClient) ListUploadedFiles(ctx context.Context) iter.Seq2[entity.SourceFile, error]
  • func (m *SourceClient) RemoveObjectTags(ctx context.Context, id string) error
  • func (m *SourceClient) SetObjectTags(ctx context.Context, id string, tags map[string]string) error

Functions

func NewMinIOClient

func NewMinIOClient(cfg config.Config) (*minio.Client, error)

Types

type EncodedObjectClient

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

func NewEncodedObjectClient

func NewEncodedObjectClient(bucketName config.EncodedObjectBucketName, client *minio.Client) *EncodedObjectClient

func (*EncodedObjectClient) GetObject

func (m *EncodedObjectClient) GetObject(ctx context.Context, mediaID string, fileName string) (io.ReadSeekCloser, error)

func (*EncodedObjectClient) Upload

func (m *EncodedObjectClient) Upload(ctx context.Context, mediaID string, localDir string) error

type SourceClient

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

func NewSourceClient

func NewSourceClient(bucketName config.SourceClientBucketName, client *minio.Client) *SourceClient

func (*SourceClient) DeleteSourceContent

func (m *SourceClient) DeleteSourceContent(ctx context.Context, id string) error

func (*SourceClient) GetSourceContent

func (m *SourceClient) GetSourceContent(ctx context.Context, id string) (io.ReadSeekCloser, error)

func (*SourceClient) ListUploadedFiles

func (m *SourceClient) ListUploadedFiles(ctx context.Context) iter.Seq2[entity.SourceFile, error]

func (*SourceClient) RemoveObjectTags

func (m *SourceClient) RemoveObjectTags(ctx context.Context, id string) error

func (*SourceClient) SetObjectTags

func (m *SourceClient) SetObjectTags(ctx context.Context, id string, tags map[string]string) error