models

Documentation

Index

• Variables
• type Lock
  • func NewLock(name string, executionDurationSec int, spanDurationSec int) (lock Lock, err error)
  • func NewLockPnc(name string, executionDurationSec int, spanDurationSec int) (lock Lock)
  • func (j Lock) GetDurationSec() int
  • func (l *Lock) SetCheckPeriod(checkPeriodSec int) (err error)
  • func (j Lock) Validate() (err error)
• type LockRecord
  • func NewLockRecord(lock Lock) LockRecord
  • func (lr *LockRecord) ApplyPatch(patch LockRecordPatch)
• type LockRecordPatch
  • func NewLockRecordPatchForCapture(durationSec int) LockRecordPatch
  • func NewLockRecordPatchForRelease(curVersion string) LockRecordPatch
• type LockRecordState
  • func (state LockRecordState) IsLock() bool

Variables

var ErrBadContext = errors.New("bad_context")

var ErrBadParam = errors.New("bad_param")

var ErrDuplicate = errors.New("duplicate")

var ErrNoLuck = errors.New("no_luck")

var ErrNotFound = errors.New("not_found")

var ErrNotSupported = errors.New("not_supported")

var ErrWrongState = errors.New("wrong_state")

Types

type Lock

type Lock struct {
	// Unique lock name
	Name string

	// Duration of lock in seconds (TTL)
	ExecutionDurationSec int

	// Interval between locks execution in seconds
	SpanDurationSec int

	// Additional lock check period
	CheckPeriodSec int
}

func NewLock

func NewLock(
	name string,
	executionDurationSec int,
	spanDurationSec int,
) (lock Lock, err error)

func NewLockPnc

func NewLockPnc(
	name string,
	executionDurationSec int,
	spanDurationSec int,
) (lock Lock)

func (Lock) GetDurationSec

func (j Lock) GetDurationSec() int

Total lock period

func (*Lock) SetCheckPeriod

func (l *Lock) SetCheckPeriod(checkPeriodSec int) (err error)

func (Lock) Validate

func (j Lock) Validate() (err error)

type LockRecord

type LockRecord struct {
	LockName    string
	Version     string
	DurationSec int
	State       LockRecordState
	Dt          time.Time
}

func NewLockRecord

func NewLockRecord(
	lock Lock,
) LockRecord

func (*LockRecord) ApplyPatch

func (lr *LockRecord) ApplyPatch(patch LockRecordPatch)

type LockRecordPatch

type LockRecordPatch struct {
	Version     string
	DurationSec int
	State       LockRecordState
	Dt          time.Time
}

func NewLockRecordPatchForCapture

func NewLockRecordPatchForCapture(
	durationSec int,
) LockRecordPatch

func NewLockRecordPatchForRelease

func NewLockRecordPatchForRelease(curVersion string) LockRecordPatch

type LockRecordState

type LockRecordState string

const (
	LockRecordStateNone   LockRecordState = ""
	LockRecordStateLock   LockRecordState = "lock"
	LockRecordStateUnlock LockRecordState = "unlock"
)

func (LockRecordState) IsLock

func (state LockRecordState) IsLock() bool