sqldb

Documentation

Index

• Constants
• type Table
  • func OpenTable(ctx context.Context, connStr string, table string, nodeID string) (*Table, error)
  • func (t *Table) Chan(ctx context.Context) chan struct{}
  • func (t *Table) GetCurrent(ctx context.Context) ([]*types.License, error)
  • func (t *Table) Reserve(ctx context.Context, licenseIDs []string, node string) (ret []*types.License, retErr error)
  • func (t *Table) UpdateInUse(ctx context.Context, licenses []*types.License) (retErr error)

Constants

const (
	QueryAllLicenses = "SELECT id, vendor, feature, usage_state, last_state_change, reserved_by_node, used_by_process FROM license_state"

	NotifyLicenseState = "NOTIFY license_state_update_channel"

	StateFree = "FREE"
)

Types

type Table

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

func OpenTable

func OpenTable(ctx context.Context, connStr string, table string, nodeID string) (*Table, error)

func (*Table) Chan

func (t *Table) Chan(ctx context.Context) chan struct{}

func (*Table) GetCurrent

func (t *Table) GetCurrent(ctx context.Context) ([]*types.License, error)

func (*Table) Reserve

func (t *Table) Reserve(ctx context.Context, licenseIDs []string, node string) (ret []*types.License, retErr error)

func (*Table) UpdateInUse

func (t *Table) UpdateInUse(ctx context.Context, licenses []*types.License) (retErr error)