upload

type Blob ¶

type Blob struct {
	PhysicalAddress string
	RelativePath    bool
	Checksum        string
	Size            int64
}

func WriteBlob(ctx context.Context, adapter block.Adapter, bucketName, address string, body io.Reader, contentLength int64, opts block.PutOpts) (*Blob, error)

type PathPartitionProvider ¶ added in v0.84.0

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

PathPartitionProvider provides path by request to upload data. The provided path is built from '<prefix>/<partition>/<unique id>'. The partition is updated every interval or when the number of IDs generated passes the specified size.

func NewPathPartitionProvider(opts ...PathProviderOption) *PathPartitionProvider

func (i *PathPartitionProvider) NewPath() string

func (i *PathPartitionProvider) ResolvePathTime(address string) (time.Time, error)

type PathProvider ¶ added in v0.84.0

type PathProvider interface {
	NewPath() string
	// ResolvePathTime - get string parse it to xid and returns the timestamp part of it
	ResolvePathTime(address string) (time.Time, error)
}

PathProvider captures the requirements from PathPartitionProvider implementation to return a new path

type PathProviderConfig ¶ added in v0.84.0

type PathProviderConfig struct {
	Size     int
	Interval time.Duration
	Prefix   string
	TellTime TimeNow
}

type PathProviderOption ¶ added in v0.84.0

type PathProviderOption func(o *PathProviderConfig)

func WithPathProviderInterval(d time.Duration) PathProviderOption

func WithPathProviderPrefix(p string) PathProviderOption

func WithPathProviderSize(size int) PathProviderOption

func WithPathProviderTellTime(t TimeNow) PathProviderOption

type TimeNow ¶ added in v0.84.0

type TimeNow func() time.Time