db

Documentation

Index

• type Lock
• type LockDB
• type SQLDB
  • func NewSQLDB(db helpers.QueryableDB, flavor string, guidProvider guidprovider.GUIDProvider) *SQLDB
  • func (db *SQLDB) Count(ctx context.Context, logger lager.Logger, lockType string) (int, error)
  • func (db *SQLDB) CreateLockTable(ctx context.Context, logger lager.Logger) error
  • func (db *SQLDB) Fetch(ctx context.Context, logger lager.Logger, key string) (*Lock, error)
  • func (db *SQLDB) FetchAll(ctx context.Context, logger lager.Logger, lockType string) ([]*Lock, error)
  • func (db *SQLDB) FetchAndRelease(ctx context.Context, logger lager.Logger, lock *Lock) (bool, error)
  • func (db *SQLDB) Lock(ctx context.Context, logger lager.Logger, resource *models.Resource, ttl int64) (*Lock, error)
  • func (db *SQLDB) Release(ctx context.Context, logger lager.Logger, resource *models.Resource) error

Types

type Lock

type Lock struct {
	*models.Resource
	TtlInSeconds  int64
	ModifiedIndex int64
	ModifiedId    string
}

type LockDB

type LockDB interface {
	Lock(ctx context.Context, logger lager.Logger, resource *models.Resource, ttl int64) (*Lock, error)
	Release(ctx context.Context, logger lager.Logger, resource *models.Resource) error
	Fetch(ctx context.Context, logger lager.Logger, key string) (*Lock, error)
	FetchAndRelease(ctx context.Context, logger lager.Logger, lock *Lock) (bool, error)
	FetchAll(ctx context.Context, logger lager.Logger, lockType string) ([]*Lock, error)
	Count(ctx context.Context, logger lager.Logger, lockType string) (int, error)
}

type SQLDB

type SQLDB struct {
	helpers.QueryableDB
	// contains filtered or unexported fields
}

func NewSQLDB

func NewSQLDB(
	db helpers.QueryableDB,
	flavor string,
	guidProvider guidprovider.GUIDProvider,
) *SQLDB

func (*SQLDB) Count

func (db *SQLDB) Count(ctx context.Context, logger lager.Logger, lockType string) (int, error)

func (*SQLDB) CreateLockTable

func (db *SQLDB) CreateLockTable(ctx context.Context, logger lager.Logger) error

func (*SQLDB) Fetch

func (db *SQLDB) Fetch(ctx context.Context, logger lager.Logger, key string) (*Lock, error)

func (*SQLDB) FetchAll

func (db *SQLDB) FetchAll(ctx context.Context, logger lager.Logger, lockType string) ([]*Lock, error)

func (*SQLDB) FetchAndRelease

func (db *SQLDB) FetchAndRelease(ctx context.Context, logger lager.Logger, lock *Lock) (bool, error)

func (*SQLDB) Lock

func (db *SQLDB) Lock(ctx context.Context, logger lager.Logger, resource *models.Resource, ttl int64) (*Lock, error)

func (*SQLDB) Release

func (db *SQLDB) Release(ctx context.Context, logger lager.Logger, resource *models.Resource) error