multiparts

Documentation

Index

• Variables
• func Migrate(ctx context.Context, d *pgxpool.Pool, _ blockparams.AdapterConfig, ...) error
• type Metadata
  • func (m Metadata) Get(k string) string
  • func (m *Metadata) Scan(src interface{}) error
  • func (m Metadata) Set(k, v string)
  • func (m Metadata) Value() (driver.Value, error)
• type MultipartUpload
• type MultipartUploadData
  • func (*MultipartUploadData) Descriptor() ([]byte, []int)
  • func (x *MultipartUploadData) GetContentType() string
  • func (x *MultipartUploadData) GetCreationDate() *timestamppb.Timestamp
  • func (x *MultipartUploadData) GetMetadata() map[string]string
  • func (x *MultipartUploadData) GetPath() string
  • func (x *MultipartUploadData) GetPhysicalAddress() string
  • func (x *MultipartUploadData) GetUploadId() string
  • func (*MultipartUploadData) ProtoMessage()
  • func (x *MultipartUploadData) ProtoReflect() protoreflect.Message
  • func (x *MultipartUploadData) Reset()
  • func (x *MultipartUploadData) String() string
• type Tracker
  • func NewDBTracker(adb db.Database) Tracker
  • func NewTracker(ms kv.StoreMessage) Tracker

Variables

var (
	ErrMultipartUploadNotFound  = errors.New("multipart upload not found")
	ErrInvalidUploadID          = errors.New("invalid upload id")
	ErrInvalidMetadataSrcFormat = errors.New("invalid metadata source format")
)

var File_multipart_proto protoreflect.FileDescriptor

Functions

func Migrate

func Migrate(ctx context.Context, d *pgxpool.Pool, _ blockparams.AdapterConfig, writer io.Writer) error

Types

type Metadata

type Metadata map[string]string

func (Metadata) Get

func (m Metadata) Get(k string) string

func (*Metadata) Scan

func (m *Metadata) Scan(src interface{}) error

func (Metadata) Set

func (m Metadata) Set(k, v string)

func (Metadata) Value

func (m Metadata) Value() (driver.Value, error)

type MultipartUpload

type MultipartUpload struct {
	// UploadID A unique identifier for the uploaded part
	UploadID string `db:"upload_id"`
	// Path Multipart path in repository
	Path string `db:"path"`
	// CreationDate Creation date of the part
	CreationDate time.Time `db:"creation_date"`
	// PhysicalAddress Physical address of the part in the storage
	PhysicalAddress string `db:"physical_address"`
	// Metadata Additional metadata as required (by storage vendor etc.)
	Metadata Metadata `db:"metadata"`
	// ContentType Original file's content-type
	ContentType string `db:"content_type"`
}

type MultipartUploadData

type MultipartUploadData struct {
	UploadId        string                 `protobuf:"bytes,1,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	Path            string                 `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	CreationDate    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=creation_date,json=creationDate,proto3" json:"creation_date,omitempty"`
	PhysicalAddress string                 `protobuf:"bytes,4,opt,name=physical_address,json=physicalAddress,proto3" json:"physical_address,omitempty"`
	Metadata        map[string]string      `` /* 157-byte string literal not displayed */
	ContentType     string                 `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

message data model for multiparts.MultipartUpload struct

func (*MultipartUploadData) Descriptor

func (*MultipartUploadData) Descriptor() ([]byte, []int)

Deprecated: Use MultipartUploadData.ProtoReflect.Descriptor instead.

func (*MultipartUploadData) GetContentType

func (x *MultipartUploadData) GetContentType() string

func (*MultipartUploadData) GetCreationDate

func (x *MultipartUploadData) GetCreationDate() *timestamppb.Timestamp

func (*MultipartUploadData) GetMetadata

func (x *MultipartUploadData) GetMetadata() map[string]string

func (*MultipartUploadData) GetPath

func (x *MultipartUploadData) GetPath() string

func (*MultipartUploadData) GetPhysicalAddress

func (x *MultipartUploadData) GetPhysicalAddress() string

func (*MultipartUploadData) GetUploadId

func (x *MultipartUploadData) GetUploadId() string

func (*MultipartUploadData) ProtoMessage

func (*MultipartUploadData) ProtoMessage()

func (*MultipartUploadData) ProtoReflect

func (x *MultipartUploadData) ProtoReflect() protoreflect.Message

func (*MultipartUploadData) Reset

func (x *MultipartUploadData) Reset()

func (*MultipartUploadData) String

func (x *MultipartUploadData) String() string

type Tracker

type Tracker interface {
	Create(ctx context.Context, multipart MultipartUpload) error
	Get(ctx context.Context, uploadID string) (*MultipartUpload, error)
	Delete(ctx context.Context, uploadID string) error
}

func NewDBTracker

func NewDBTracker(adb db.Database) Tracker

func NewTracker

func NewTracker(ms kv.StoreMessage) Tracker