services

package

v0.0.0-...-1897f70 Latest Latest Go to latest Published: Oct 12, 2025 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/teapartydev/storage

Links

Open Source Insights

Documentation ¶

Index ¶

type BucketService
- func NewBucketService(db *pgxpool.Pool, job *river.Client[pgx.Tx], logger *zap.Logger) *BucketService
type ObjectService
- func NewObjectService(db *pgxpool.Pool, storage *storage.Storage, job *river.Client[pgx.Tx], ...) *ObjectService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BucketService ¶

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

func NewBucketService ¶

func NewBucketService(db *pgxpool.Pool, job *river.Client[pgx.Tx], logger *zap.Logger) *BucketService

func (*BucketService) CreateBucket ¶

func (bs *BucketService) CreateBucket(ctx context.Context, bucketCreate *models.BucketCreate) (*models.Bucket, error)

func (*BucketService) DeleteBucket ¶

func (bs *BucketService) DeleteBucket(ctx context.Context, id string) error

func (*BucketService) DisableBucket ¶

func (bs *BucketService) DisableBucket(ctx context.Context, id string) (*models.Bucket, error)

func (*BucketService) EmptyBucket ¶

func (bs *BucketService) EmptyBucket(ctx context.Context, id string) error

func (*BucketService) EnableBucket ¶

func (bs *BucketService) EnableBucket(ctx context.Context, id string) (*models.Bucket, error)

func (*BucketService) GetBucket ¶

func (bs *BucketService) GetBucket(ctx context.Context, id string) (*models.Bucket, error)

func (*BucketService) GetBucketSize ¶

func (bs *BucketService) GetBucketSize(ctx context.Context, id string) (*models.BucketSize, error)

func (*BucketService) ListAllBuckets ¶

func (bs *BucketService) ListAllBuckets(ctx context.Context) ([]*models.Bucket, error)

func (*BucketService) SearchBuckets ¶

func (bs *BucketService) SearchBuckets(ctx context.Context, name string) ([]*models.Bucket, error)

func (*BucketService) UpdateBucket ¶

func (bs *BucketService) UpdateBucket(ctx context.Context, bucketUpdate *models.BucketUpdate) (*models.Bucket, error)

type ObjectService ¶

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

func NewObjectService ¶

func NewObjectService(db *pgxpool.Pool, storage *storage.Storage, job *river.Client[pgx.Tx], config *config.Config, logger *zap.Logger) *ObjectService

func (*ObjectService) CompletePreSignedUploadSession ¶

func (os *ObjectService) CompletePreSignedUploadSession(ctx context.Context, bucketId string, objectId string) error

func (*ObjectService) CreatePreSignedDownloadSession ¶

func (os *ObjectService) CreatePreSignedDownloadSession(ctx context.Context, bucketId string, objectId string, expiresIn int64) (*models.PreSignedDownloadSession, error)

func (*ObjectService) CreatePreSignedUploadSession ¶

func (os *ObjectService) CreatePreSignedUploadSession(ctx context.Context, preSignedUploadSessionCreate *models.PreSignedUploadSessionCreate) (*models.PreSignedUploadSession, error)

func (*ObjectService) DeleteObject ¶

func (os *ObjectService) DeleteObject(ctx context.Context, bucketId string, objectId string) error

func (*ObjectService) GetObject ¶

func (os *ObjectService) GetObject(ctx context.Context, bucketId string, objectId string) (*models.Object, error)

func (*ObjectService) SearchObjects ¶

func (os *ObjectService) SearchObjects(ctx context.Context, bucketId string, objectPath string, limit int32, offset int32) ([]*models.Object, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL