database

Documentation

Index

• type AddContainerAddrParams
• type AddContainerAliasParams
• type AddContainerParams
• type AddEstContainerParams
• type Addr
• type Container
• type ContainerAlias
• type DB
  • func NewDB(ctx context.Context, db *sql.DB) (*DB, error)
  • func (d *DB) Begin(ctx context.Context, logger *zap.Logger) (*TX, error)
• type DBTX
• type EstContainer
• type GetEstContainersRow
• type Queries
  • func New(db DBTX) *Queries
  • func Prepare(ctx context.Context, db DBTX) (*Queries, error)
  • func (q *Queries) AddContainer(ctx context.Context, arg AddContainerParams) error
  • func (q *Queries) AddContainerAddr(ctx context.Context, arg AddContainerAddrParams) error
  • func (q *Queries) AddContainerAlias(ctx context.Context, arg AddContainerAliasParams) error
  • func (q *Queries) AddEstContainer(ctx context.Context, arg AddEstContainerParams) error
  • func (q *Queries) Close() error
  • func (q *Queries) ContainerExists(ctx context.Context, id string) (interface{}, error)
  • func (q *Queries) DeleteContainer(ctx context.Context, id string) error
  • func (q *Queries) DeleteContainerAddrs(ctx context.Context, containerID string) error
  • func (q *Queries) DeleteContainerAliases(ctx context.Context, containerID string) error
  • func (q *Queries) DeleteEstContainers(ctx context.Context, srcContainerID string) error
  • func (q *Queries) GetContainerAddrs(ctx context.Context, containerID string) ([][]byte, error)
  • func (q *Queries) GetContainerID(ctx context.Context, name string) (string, error)
  • func (q *Queries) GetContainerIDAndNameFromAlias(ctx context.Context, containerAlias string) (Container, error)
  • func (q *Queries) GetContainerName(ctx context.Context, id string) (string, error)
  • func (q *Queries) GetContainers(ctx context.Context) ([]Container, error)
  • func (q *Queries) GetEstContainers(ctx context.Context, srcContainerID string) ([]GetEstContainersRow, error)
  • func (q *Queries) WithTx(tx *sql.Tx) *Queries
• type TX
  • func (t *TX) Commit(ctx context.Context) error
  • func (t *TX) Rollback(ctx context.Context) bool

Types

type AddContainerAddrParams

type AddContainerAddrParams struct {
	Addr        []byte
	ContainerID string
}

type AddContainerAliasParams

type AddContainerAliasParams struct {
	ContainerID    string
	ContainerAlias string
}

type AddContainerParams

type AddContainerParams struct {
	ID   string
	Name string
}

type AddEstContainerParams

type AddEstContainerParams struct {
	SrcContainerID string
	DstContainerID string
}

type Addr

type Addr struct {
	Addr        []byte
	ContainerID string
}

type Container

type Container struct {
	ID   string
	Name string
}

type ContainerAlias

type ContainerAlias struct {
	ContainerID    string
	ContainerAlias string
}

type DB

type DB struct {
	*Queries
	// contains filtered or unexported fields
}

func NewDB

func NewDB(ctx context.Context, db *sql.DB) (*DB, error)

func (*DB) Begin

func (d *DB) Begin(ctx context.Context, logger *zap.Logger) (*TX, error)

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type EstContainer

type EstContainer struct {
	SrcContainerID string
	DstContainerID string
}

type GetEstContainersRow

type GetEstContainersRow struct {
	DstContainerID string
	Name           string
}

type Queries

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

func New

func New(db DBTX) *Queries

func Prepare

func Prepare(ctx context.Context, db DBTX) (*Queries, error)

func (*Queries) AddContainer

func (q *Queries) AddContainer(ctx context.Context, arg AddContainerParams) error

func (*Queries) AddContainerAddr

func (q *Queries) AddContainerAddr(ctx context.Context, arg AddContainerAddrParams) error

func (*Queries) AddContainerAlias

func (q *Queries) AddContainerAlias(ctx context.Context, arg AddContainerAliasParams) error

func (*Queries) AddEstContainer

func (q *Queries) AddEstContainer(ctx context.Context, arg AddEstContainerParams) error

func (*Queries) Close

func (q *Queries) Close() error

func (*Queries) ContainerExists

func (q *Queries) ContainerExists(ctx context.Context, id string) (interface{}, error)

func (*Queries) DeleteContainer

func (q *Queries) DeleteContainer(ctx context.Context, id string) error

func (*Queries) DeleteContainerAddrs

func (q *Queries) DeleteContainerAddrs(ctx context.Context, containerID string) error

func (*Queries) DeleteContainerAliases

func (q *Queries) DeleteContainerAliases(ctx context.Context, containerID string) error

func (*Queries) DeleteEstContainers

func (q *Queries) DeleteEstContainers(ctx context.Context, srcContainerID string) error

func (*Queries) GetContainerAddrs

func (q *Queries) GetContainerAddrs(ctx context.Context, containerID string) ([][]byte, error)

func (*Queries) GetContainerID

func (q *Queries) GetContainerID(ctx context.Context, name string) (string, error)

func (*Queries) GetContainerIDAndNameFromAlias

func (q *Queries) GetContainerIDAndNameFromAlias(ctx context.Context, containerAlias string) (Container, error)

func (*Queries) GetContainerName

func (q *Queries) GetContainerName(ctx context.Context, id string) (string, error)

func (*Queries) GetContainers

func (q *Queries) GetContainers(ctx context.Context) ([]Container, error)

func (*Queries) GetEstContainers

func (q *Queries) GetEstContainers(ctx context.Context, srcContainerID string) ([]GetEstContainersRow, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type TX

type TX struct {
	*Queries
	// contains filtered or unexported fields
}

func (*TX) Commit

func (t *TX) Commit(ctx context.Context) error

func (*TX) Rollback

func (t *TX) Rollback(ctx context.Context) bool