service

Documentation

Index

• func Initialize(ctx context.Context)
• type Type
  • func NewService(db *dao.Type) *Type
  • func (s *Type) AcquireLock(ctx context.Context, name, ownerID string, duration time.Duration, ...) (ok bool, err error)
  • func (s *Type) LoadLockByName(ctx context.Context, name string) (lock *model.Lock, err error)

Functions

func Initialize

func Initialize(ctx context.Context)

Types

type Type

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

var Instance *Type

func NewService

func NewService(db *dao.Type) *Type

func (*Type) AcquireLock

func (s *Type) AcquireLock(ctx context.Context,
	name, ownerID string,
	duration time.Duration,
	isRenewal bool,
) (ok bool, err error)

func (*Type) LoadLockByName

func (s *Type) LoadLockByName(ctx context.Context,
	name string) (lock *model.Lock, err error)