util

Documentation

Index

• Constants
• Variables
• func AddShardFilesToPacker(spath, id string, pkr *shardpacker.Packer) (err error)
• func ShardNameToDateRange(nm string) (s, e time.Time, err error)
• type ShardID
  • func GetShardId(t time.Time) ShardID
  • func NextShardId(curr ShardID) ShardID
• type Timeframe
• type UploadID
• type UploadTracker
  • func NewUploadTracker() UploadTracker
  • func (t *UploadTracker) EnterUpload(uid UploadID) (err error)
  • func (t *UploadTracker) ExitUpload(uid UploadID) (err error)

Constants

const (
	ShardSet int64 = 0x1ffff //this 1.517

)

Variables

var (
	ErrUploadInProgress    = errors.New("Shard upload already in progress")
	ErrUploadNotInProgress = errors.New("Shard upload not in progress")
)

Functions

func AddShardFilesToPacker

func AddShardFilesToPacker(spath, id string, pkr *shardpacker.Packer) (err error)

func ShardNameToDateRange

func ShardNameToDateRange(nm string) (s, e time.Time, err error)

Types

type ShardID

type ShardID int64

func GetShardId

func GetShardId(t time.Time) ShardID

this should generally be inlined everywhere

func NextShardId

func NextShardId(curr ShardID) ShardID

type Timeframe

type Timeframe struct {
	Start time.Time
	End   time.Time
}

type UploadID

type UploadID struct {
	CID     uint64    //customer ID
	IdxUUID uuid.UUID //indexer UUID
	Well    string    //well name
	Shard   string    //shard ID
}

type UploadTracker

type UploadTracker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewUploadTracker

func NewUploadTracker() UploadTracker

func (*UploadTracker) EnterUpload

func (t *UploadTracker) EnterUpload(uid UploadID) (err error)

EnterUpload attempts to claim an upload ID, if an upload with the existing ID exists an error is returnd

func (*UploadTracker) ExitUpload

func (t *UploadTracker) ExitUpload(uid UploadID) (err error)

ExitUpload releases an existing upload lock for a given shard if the shard wasn't locked, and error is returned