db

package
v0.0.0-...-9f60fe2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 2, 2023 License: MPL-2.0 Imports: 7 Imported by: 0

README

db

Queries

Queries prefixed with and Mx return the data as a corresponding api type.

Documentation

Index

Constants

View Source 
const BuildCreate = `` /* 342-byte string literal not displayed */
View Source 
const BuildGet = `` /* 178-byte string literal not displayed */
View Source 
const BuildGetUsedBy = `` /* 433-byte string literal not displayed */
View Source 
const BuildUpdate = `` /* 366-byte string literal not displayed */
View Source 
const EndpointCheck = `-- name: EndpointCheck :one
SELECT id, endpoint_id, project_id, created_at FROM unweave.endpoint_check WHERE id = $1
`
View Source 
const EndpointCheckCreate = `-- name: EndpointCheckCreate :exec
INSERT INTO unweave.endpoint_check (id, endpoint_id, project_id) VALUES ($1, $2, $3)
`
View Source 
const EndpointCheckStepCreate = `` /* 134-byte string literal not displayed */
View Source 
const EndpointCheckStepUpdate = `` /* 196-byte string literal not displayed */
View Source 
const EndpointCheckSteps = `` /* 142-byte string literal not displayed */
View Source 
const EndpointCreate = `` /* 146-byte string literal not displayed */
View Source 
const EndpointDelete = `-- name: EndpointDelete :exec
DELETE FROM unweave.endpoint WHERE id = $1
`
View Source 
const EndpointEval = `-- name: EndpointEval :many
SELECT endpoint_id, eval_id FROM unweave.endpoint_eval WHERE endpoint_id = $1
`
View Source 
const EndpointEvalAttach = `-- name: EndpointEvalAttach :exec
INSERT INTO unweave.endpoint_eval (endpoint_id, eval_id) VALUES ($1, $2)
`
View Source 
const EndpointGet = `` /* 169-byte string literal not displayed */
View Source 
const EndpointVersion = `` /* 173-byte string literal not displayed */
View Source 
const EndpointVersionCreate = `` /* 171-byte string literal not displayed */
View Source 
const EndpointVersionDemote = `-- name: EndpointVersionDemote :exec
UPDATE unweave.endpoint_version
SET primary_version = FALSE
WHERE endpoint_id = $1
`
View Source 
const EndpointVersionList = `` /* 187-byte string literal not displayed */
View Source 
const EndpointVersionPromote = `-- name: EndpointVersionPromote :exec
UPDATE unweave.endpoint_version
SET primary_version = TRUE
WHERE id = $1
`
View Source 
const EndpointsForProject = `` /* 151-byte string literal not displayed */
View Source 
const EvalCreate = `-- name: EvalCreate :exec
INSERT INTO unweave.eval (id, exec_id, http_address, project_id) VALUES ($1, $2, $3, $4)
`
View Source 
const EvalDelete = `-- name: EvalDelete :exec
DELETE FROM unweave.eval WHERE id = $1
`
View Source 
const EvalGet = `-- name: EvalGet :one
SELECT id, exec_id, http_address, project_id FROM unweave.eval WHERE id = $1
`
View Source 
const EvalList = `-- name: EvalList :many
SELECT id, exec_id, http_address, created_at FROM unweave.eval WHERE id = ANY($1::text[])
`
View Source 
const EvalListForProject = `-- name: EvalListForProject :many
SELECT id, exec_id, http_address, project_id from unweave.eval WHERE project_id = $1
`
View Source 
const ExecCreate = `` /* 315-byte string literal not displayed */
View Source 
const ExecGet = `` /* 245-byte string literal not displayed */
View Source 
const ExecGetAllActive = `` /* 280-byte string literal not displayed */
View Source 
const ExecList = `` /* 424-byte string literal not displayed */
View Source 
const ExecListActiveByProvider = `` /* 316-byte string literal not displayed */
View Source 
const ExecListByProvider = `` /* 254-byte string literal not displayed */
View Source 
const ExecSSHKeyDelete = `-- name: ExecSSHKeyDelete :exec
DELETE FROM unweave.exec_ssh_key
WHERE exec_id = $1
  AND ssh_key_id = $2
`
View Source 
const ExecSSHKeyGet = `-- name: ExecSSHKeyGet :one
SELECT exec_id, ssh_key_id
FROM unweave.exec_ssh_key
WHERE exec_id = $1
  AND ssh_key_id = $2
`
View Source 
const ExecSSHKeyInsert = `-- name: ExecSSHKeyInsert :exec
INSERT INTO unweave.exec_ssh_key (exec_id, ssh_key_id)
VALUES ($1, $2)
`
View Source 
const ExecSSHKeysGetByExecID = `-- name: ExecSSHKeysGetByExecID :many
SELECT exec_id, ssh_key_id
FROM unweave.exec_ssh_key
WHERE exec_id = $1
`
View Source 
const ExecSetError = `-- name: ExecSetError :exec
update unweave.exec
set status = 'error'::unweave.exec_status,
    error  = $2
where id = $1
`
View Source 
const ExecSetFailed = `-- name: ExecSetFailed :exec
update unweave.exec
set status = 'failed'::unweave.exec_status,
    error  = $2
where id = $1
`
View Source 
const ExecStatusUpdate = `` /* 166-byte string literal not displayed */
View Source 
const ExecUpdateConnectionInfo = `` /* 141-byte string literal not displayed */
View Source 
const ExecUpdateNetwork = `` /* 131-byte string literal not displayed */
View Source 
const ExecVolumeCreate = `-- name: ExecVolumeCreate :exec
insert into unweave.exec_volume (exec_id, volume_id, mount_path)
values ($1, $2, $3)
`
View Source 
const ExecVolumeDelete = `-- name: ExecVolumeDelete :exec
delete from unweave.exec_volume
where exec_id = $1
`
View Source 
const ExecVolumeGet = `-- name: ExecVolumeGet :many
select exec_id, volume_id, mount_path from unweave.exec_volume as ev where ev.exec_id = $1
`
View Source 
const MxExecGet = `` /* 184-byte string literal not displayed */
View Source 
const MxExecsGet = `` /* 193-byte string literal not displayed */
View Source 
const NodeCreate = `` /* 218-byte string literal not displayed */
View Source 
const NodeStatusUpdate = `` /* 182-byte string literal not displayed */
View Source 
const ProjectGet = `-- name: ProjectGet :one
select id, default_build_id
from unweave.project
where id = $1
`
View Source 
const SSHKeyAdd = `-- name: SSHKeyAdd :exec
insert into unweave.ssh_key (owner_id, name, public_key)
values ($1, $2, $3)
`
View Source 
const SSHKeyGetByName = `` /* 148-byte string literal not displayed */
View Source 
const SSHKeyGetByPublicKey = `` /* 159-byte string literal not displayed */
View Source 
const SSHKeysGet = `` /* 128-byte string literal not displayed */
View Source 
const SSHKeysGetByIDs = `` /* 140-byte string literal not displayed */
View Source 
const VolumeCreate = `` /* 203-byte string literal not displayed */
View Source 
const VolumeDelete = `-- name: VolumeDelete :exec
delete from unweave.volume
where id = $1
`
View Source 
const VolumeGet = `` /* 173-byte string literal not displayed */
View Source 
const VolumeList = `` /* 148-byte string literal not displayed */
View Source 
const VolumeUpdate = `-- name: VolumeUpdate :exec
update unweave.volume
set size = $2
where id = $1
`

Variables

This section is empty.

Functions

func Connect 

func Connect(cfg Config) (*sql.DB, error)

func NullStringFrom 

func NullStringFrom(s *string) sql.NullString

func NullTimeFrom 

func NullTimeFrom(t time.Time) sql.NullTime

Types

type BuildCreateParams 

type BuildCreateParams struct {
	ProjectID   string    `json:"projectID"`
	BuilderType string    `json:"builderType"`
	Name        string    `json:"name"`
	CreatedBy   string    `json:"createdBy"`
	StartedAt   time.Time `json:"startedAt"`
}

type BuildGetUsedByRow 

type BuildGetUsedByRow struct {
	ID           string            `json:"id"`
	Name         string            `json:"name"`
	Region       string            `json:"region"`
	CreatedBy    string            `json:"createdBy"`
	CreatedAt    time.Time         `json:"createdAt"`
	ReadyAt      sql.NullTime      `json:"readyAt"`
	ExitedAt     sql.NullTime      `json:"exitedAt"`
	Status       UnweaveExecStatus `json:"status"`
	ProjectID    string            `json:"projectID"`
	Error        sql.NullString    `json:"error"`
	BuildID      sql.NullString    `json:"buildID"`
	Spec         json.RawMessage   `json:"spec"`
	CommitID     sql.NullString    `json:"commitID"`
	GitRemoteUrl sql.NullString    `json:"gitRemoteUrl"`
	Command      []string          `json:"command"`
	Metadata     json.RawMessage   `json:"metadata"`
	Image        string            `json:"image"`
	Provider     string            `json:"provider"`
	Provider_2   string            `json:"provider2"`
}

type BuildUpdateParams 

type BuildUpdateParams struct {
	ID         string             `json:"id"`
	Status     UnweaveBuildStatus `json:"status"`
	MetaData   json.RawMessage    `json:"metaData"`
	StartedAt  time.Time          `json:"startedAt"`
	FinishedAt time.Time          `json:"finishedAt"`
}

type Config 

type Config struct {
	Host     string `json:"host" env:"UNWEAVE_DB_HOST"`
	Port     int    `json:"port" env:"UNWEAVE_DB_PORT"`
	Name     string `json:"name" env:"UNWEAVE_DB_NAME"`
	User     string `json:"user" env:"UNWEAVE_DB_USER"`
	Password string `json:"password" env:"UNWEAVE_DB_PASSWORD"`
}

type DB 

type DB 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 DBTX 

type DBTX interface {
	DB
	Tx
}

type EndpointCheckCreateParams 

type EndpointCheckCreateParams struct {
	ID         string `json:"id"`
	EndpointID string `json:"endpointID"`
	ProjectID  string `json:"projectID"`
}

type EndpointCheckStepCreateParams 

type EndpointCheckStepCreateParams struct {
	ID      string         `json:"id"`
	CheckID string         `json:"checkID"`
	EvalID  string         `json:"evalID"`
	Input   sql.NullString `json:"input"`
}

type EndpointCheckStepUpdateParams 

type EndpointCheckStepUpdateParams struct {
	Input     sql.NullString `json:"input"`
	Output    sql.NullString `json:"output"`
	Assertion sql.NullString `json:"assertion"`
	ID        sql.NullString `json:"id"`
}

type EndpointCreateParams 

type EndpointCreateParams struct {
	ID          string    `json:"id"`
	Name        string    `json:"name"`
	Icon        string    `json:"icon"`
	ProjectID   string    `json:"projectID"`
	HttpAddress string    `json:"httpAddress"`
	CreatedAt   time.Time `json:"createdAt"`
}

type EndpointEvalAttachParams 

type EndpointEvalAttachParams struct {
	EndpointID string `json:"endpointID"`
	EvalID     string `json:"evalID"`
}

type EndpointGetParams 

type EndpointGetParams struct {
	ID        string `json:"id"`
	ProjectID string `json:"projectID"`
}

type EndpointVersionCreateParams 

type EndpointVersionCreateParams struct {
	ID          string    `json:"id"`
	EndpointID  string    `json:"endpointID"`
	ExecID      string    `json:"execID"`
	ProjectID   string    `json:"projectID"`
	HttpAddress string    `json:"httpAddress"`
	CreatedAt   time.Time `json:"createdAt"`
}

type EvalCreateParams 

type EvalCreateParams struct {
	ID          string `json:"id"`
	ExecID      string `json:"execID"`
	HttpAddress string `json:"httpAddress"`
	ProjectID   string `json:"projectID"`
}

type EvalGetRow 

type EvalGetRow struct {
	ID          string `json:"id"`
	ExecID      string `json:"execID"`
	HttpAddress string `json:"httpAddress"`
	ProjectID   string `json:"projectID"`
}

type EvalListForProjectRow 

type EvalListForProjectRow struct {
	ID          string `json:"id"`
	ExecID      string `json:"execID"`
	HttpAddress string `json:"httpAddress"`
	ProjectID   string `json:"projectID"`
}

type EvalListRow 

type EvalListRow struct {
	ID          string    `json:"id"`
	ExecID      string    `json:"execID"`
	HttpAddress string    `json:"httpAddress"`
	CreatedAt   time.Time `json:"createdAt"`
}

type ExecCreateParams 

type ExecCreateParams struct {
	ID           string          `json:"id"`
	CreatedBy    string          `json:"createdBy"`
	ProjectID    string          `json:"projectID"`
	Region       string          `json:"region"`
	Name         string          `json:"name"`
	Spec         json.RawMessage `json:"spec"`
	Metadata     json.RawMessage `json:"metadata"`
	CommitID     sql.NullString  `json:"commitID"`
	GitRemoteUrl sql.NullString  `json:"gitRemoteUrl"`
	Command      []string        `json:"command"`
	BuildID      sql.NullString  `json:"buildID"`
	Image        string          `json:"image"`
	Provider     string          `json:"provider"`
}

type ExecListParams 

type ExecListParams struct {
	FilterProvider  sql.NullString `json:"filterProvider"`
	FilterProjectID sql.NullString `json:"filterProjectID"`
	FilterActive    interface{}    `json:"filterActive"`
}

type ExecSSHKeyDeleteParams 

type ExecSSHKeyDeleteParams struct {
	ExecID   string `json:"execID"`
	SshKeyID string `json:"sshKeyID"`
}

type ExecSSHKeyGetParams 

type ExecSSHKeyGetParams struct {
	ExecID   string `json:"execID"`
	SshKeyID string `json:"sshKeyID"`
}

type ExecSSHKeyInsertParams 

type ExecSSHKeyInsertParams struct {
	ExecID   string `json:"execID"`
	SshKeyID string `json:"sshKeyID"`
}

type ExecSetErrorParams 

type ExecSetErrorParams struct {
	ID    string         `json:"id"`
	Error sql.NullString `json:"error"`
}

type ExecSetFailedParams 

type ExecSetFailedParams struct {
	ID    string         `json:"id"`
	Error sql.NullString `json:"error"`
}

type ExecStatusUpdateParams 

type ExecStatusUpdateParams struct {
	ID       string            `json:"id"`
	Status   UnweaveExecStatus `json:"status"`
	ReadyAt  sql.NullTime      `json:"readyAt"`
	ExitedAt sql.NullTime      `json:"exitedAt"`
}

type ExecUpdateConnectionInfoParams 

type ExecUpdateConnectionInfoParams struct {
	ID             string          `json:"id"`
	ConnectionInfo json.RawMessage `json:"connectionInfo"`
}

type ExecUpdateNetworkParams 

type ExecUpdateNetworkParams struct {
	ID          string          `json:"id"`
	HttpService json.RawMessage `json:"httpService"`
}

type ExecVolumeCreateParams 

type ExecVolumeCreateParams struct {
	ExecID    string `json:"execID"`
	VolumeID  string `json:"volumeID"`
	MountPath string `json:"mountPath"`
}

type MxExecGetRow 

type MxExecGetRow struct {
	ID        string            `json:"id"`
	Name      string            `json:"name"`
	Status    UnweaveExecStatus `json:"status"`
	Provider  string            `json:"provider"`
	Region    string            `json:"region"`
	CreatedAt time.Time         `json:"createdAt"`
	Metadata  json.RawMessage   `json:"metadata"`
}

type MxExecsGetRow 

type MxExecsGetRow struct {
	ID        string            `json:"id"`
	Name      string            `json:"name"`
	Status    UnweaveExecStatus `json:"status"`
	Provider  string            `json:"provider"`
	Region    string            `json:"region"`
	CreatedAt time.Time         `json:"createdAt"`
	Metadata  json.RawMessage   `json:"metadata"`
}

type NodeCreateParams 

type NodeCreateParams struct {
	ID        string          `json:"id"`
	Provider  string          `json:"provider"`
	Region    string          `json:"region"`
	Metadata  json.RawMessage `json:"metadata"`
	Status    string          `json:"status"`
	OwnerID   string          `json:"ownerID"`
	SshKeyIds []string        `json:"sshKeyIds"`
}

type NodeStatusUpdateParams 

type NodeStatusUpdateParams struct {
	ID           string       `json:"id"`
	Status       string       `json:"status"`
	ReadyAt      sql.NullTime `json:"readyAt"`
	TerminatedAt sql.NullTime `json:"terminatedAt"`
}

type NullUnweaveBuildStatus 

type NullUnweaveBuildStatus struct {
	UnweaveBuildStatus UnweaveBuildStatus
	Valid              bool // Valid is true if UnweaveBuildStatus is not NULL
}

func (*NullUnweaveBuildStatus) Scan 

func (ns *NullUnweaveBuildStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullUnweaveBuildStatus) Value 

func (ns NullUnweaveBuildStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullUnweaveExecStatus 

type NullUnweaveExecStatus struct {
	UnweaveExecStatus UnweaveExecStatus
	Valid             bool // Valid is true if UnweaveExecStatus is not NULL
}

func (*NullUnweaveExecStatus) Scan 

func (ns *NullUnweaveExecStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullUnweaveExecStatus) Value 

func (ns NullUnweaveExecStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Querier 

type Querier interface {
	BuildCreate(ctx context.Context, arg BuildCreateParams) (string, error)
	BuildGet(ctx context.Context, id string) (UnweaveBuild, error)
	BuildGetUsedBy(ctx context.Context, id string) ([]BuildGetUsedByRow, error)
	BuildUpdate(ctx context.Context, arg BuildUpdateParams) error
	EndpointCheck(ctx context.Context, id string) (UnweaveEndpointCheck, error)
	EndpointCheckCreate(ctx context.Context, arg EndpointCheckCreateParams) error
	EndpointCheckStepCreate(ctx context.Context, arg EndpointCheckStepCreateParams) error
	EndpointCheckStepUpdate(ctx context.Context, arg EndpointCheckStepUpdateParams) error
	EndpointCheckSteps(ctx context.Context, checkID string) ([]UnweaveEndpointCheckStep, error)
	EndpointCreate(ctx context.Context, arg EndpointCreateParams) error
	EndpointDelete(ctx context.Context, id string) error
	EndpointEval(ctx context.Context, endpointID string) ([]UnweaveEndpointEval, error)
	EndpointEvalAttach(ctx context.Context, arg EndpointEvalAttachParams) error
	EndpointGet(ctx context.Context, arg EndpointGetParams) (UnweaveEndpoint, error)
	EndpointVersion(ctx context.Context, id string) (UnweaveEndpointVersion, error)
	EndpointVersionCreate(ctx context.Context, arg EndpointVersionCreateParams) error
	EndpointVersionDemote(ctx context.Context, endpointID string) error
	EndpointVersionList(ctx context.Context, endpointID string) ([]UnweaveEndpointVersion, error)
	EndpointVersionPromote(ctx context.Context, id string) error
	EndpointsForProject(ctx context.Context, projectID string) ([]UnweaveEndpoint, error)
	EvalCreate(ctx context.Context, arg EvalCreateParams) error
	EvalDelete(ctx context.Context, id string) error
	EvalGet(ctx context.Context, id string) (EvalGetRow, error)
	EvalList(ctx context.Context, dollar_1 []string) ([]EvalListRow, error)
	EvalListForProject(ctx context.Context, projectID string) ([]EvalListForProjectRow, error)
	ExecCreate(ctx context.Context, arg ExecCreateParams) error
	ExecGet(ctx context.Context, idOrName string) (UnweaveExec, error)
	ExecGetAllActive(ctx context.Context) ([]UnweaveExec, error)
	ExecList(ctx context.Context, arg ExecListParams) ([]UnweaveExec, error)
	ExecListActiveByProvider(ctx context.Context, provider string) ([]UnweaveExec, error)
	ExecListByProvider(ctx context.Context, provider string) ([]UnweaveExec, error)
	ExecSSHKeyDelete(ctx context.Context, arg ExecSSHKeyDeleteParams) error
	ExecSSHKeyGet(ctx context.Context, arg ExecSSHKeyGetParams) (UnweaveExecSshKey, error)
	ExecSSHKeyInsert(ctx context.Context, arg ExecSSHKeyInsertParams) error
	ExecSSHKeysGetByExecID(ctx context.Context, execID string) ([]UnweaveExecSshKey, error)
	ExecSetError(ctx context.Context, arg ExecSetErrorParams) error
	ExecSetFailed(ctx context.Context, arg ExecSetFailedParams) error
	ExecStatusUpdate(ctx context.Context, arg ExecStatusUpdateParams) error
	ExecUpdateConnectionInfo(ctx context.Context, arg ExecUpdateConnectionInfoParams) error
	ExecUpdateNetwork(ctx context.Context, arg ExecUpdateNetworkParams) error
	ExecVolumeCreate(ctx context.Context, arg ExecVolumeCreateParams) error
	ExecVolumeDelete(ctx context.Context, execID string) error
	ExecVolumeGet(ctx context.Context, execID string) ([]UnweaveExecVolume, error)
	//-----------------------------------------------------------------
	// The queries below return data in the format expected by the API.
	//-----------------------------------------------------------------
	MxExecGet(ctx context.Context, id string) (MxExecGetRow, error)
	MxExecsGet(ctx context.Context, projectID string) ([]MxExecsGetRow, error)
	NodeCreate(ctx context.Context, arg NodeCreateParams) error
	NodeStatusUpdate(ctx context.Context, arg NodeStatusUpdateParams) error
	ProjectGet(ctx context.Context, id string) (UnweaveProject, error)
	SSHKeyAdd(ctx context.Context, arg SSHKeyAddParams) error
	SSHKeyGetByName(ctx context.Context, arg SSHKeyGetByNameParams) (UnweaveSshKey, error)
	SSHKeyGetByPublicKey(ctx context.Context, arg SSHKeyGetByPublicKeyParams) (UnweaveSshKey, error)
	SSHKeysGet(ctx context.Context, ownerID string) ([]UnweaveSshKey, error)
	SSHKeysGetByIDs(ctx context.Context, ids []string) ([]UnweaveSshKey, error)
	VolumeCreate(ctx context.Context, arg VolumeCreateParams) (UnweaveVolume, error)
	VolumeDelete(ctx context.Context, id string) error
	VolumeGet(ctx context.Context, arg VolumeGetParams) (UnweaveVolume, error)
	VolumeList(ctx context.Context, projectID string) ([]UnweaveVolume, error)
	VolumeUpdate(ctx context.Context, arg VolumeUpdateParams) error
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) BuildCreate 

func (q *Queries) BuildCreate(ctx context.Context, arg BuildCreateParams) (string, error)

func (*Queries) BuildGet 

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

func (*Queries) BuildGetUsedBy 

func (q *Queries) BuildGetUsedBy(ctx context.Context, id string) ([]BuildGetUsedByRow, error)

func (*Queries) BuildUpdate 

func (q *Queries) BuildUpdate(ctx context.Context, arg BuildUpdateParams) error

func (*Queries) EndpointCheck 

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

func (*Queries) EndpointCheckCreate 

func (q *Queries) EndpointCheckCreate(ctx context.Context, arg EndpointCheckCreateParams) error

func (*Queries) EndpointCheckStepCreate 

func (q *Queries) EndpointCheckStepCreate(ctx context.Context, arg EndpointCheckStepCreateParams) error

func (*Queries) EndpointCheckStepUpdate 

func (q *Queries) EndpointCheckStepUpdate(ctx context.Context, arg EndpointCheckStepUpdateParams) error

func (*Queries) EndpointCheckSteps 

func (q *Queries) EndpointCheckSteps(ctx context.Context, checkID string) ([]UnweaveEndpointCheckStep, error)

func (*Queries) EndpointCreate 

func (q *Queries) EndpointCreate(ctx context.Context, arg EndpointCreateParams) error

func (*Queries) EndpointDelete 

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

func (*Queries) EndpointEval 

func (q *Queries) EndpointEval(ctx context.Context, endpointID string) ([]UnweaveEndpointEval, error)

func (*Queries) EndpointEvalAttach 

func (q *Queries) EndpointEvalAttach(ctx context.Context, arg EndpointEvalAttachParams) error

func (*Queries) EndpointGet 

func (q *Queries) EndpointGet(ctx context.Context, arg EndpointGetParams) (UnweaveEndpoint, error)

func (*Queries) EndpointVersion 

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

func (*Queries) EndpointVersionCreate 

func (q *Queries) EndpointVersionCreate(ctx context.Context, arg EndpointVersionCreateParams) error

func (*Queries) EndpointVersionDemote 

func (q *Queries) EndpointVersionDemote(ctx context.Context, endpointID string) error

func (*Queries) EndpointVersionList 

func (q *Queries) EndpointVersionList(ctx context.Context, endpointID string) ([]UnweaveEndpointVersion, error)

func (*Queries) EndpointVersionPromote 

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

func (*Queries) EndpointsForProject 

func (q *Queries) EndpointsForProject(ctx context.Context, projectID string) ([]UnweaveEndpoint, error)

func (*Queries) EvalCreate 

func (q *Queries) EvalCreate(ctx context.Context, arg EvalCreateParams) error

func (*Queries) EvalDelete 

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

func (*Queries) EvalGet 

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

func (*Queries) EvalList 

func (q *Queries) EvalList(ctx context.Context, dollar_1 []string) ([]EvalListRow, error)

func (*Queries) EvalListForProject 

func (q *Queries) EvalListForProject(ctx context.Context, projectID string) ([]EvalListForProjectRow, error)

func (*Queries) ExecCreate 

func (q *Queries) ExecCreate(ctx context.Context, arg ExecCreateParams) error

func (*Queries) ExecGet 

func (q *Queries) ExecGet(ctx context.Context, idOrName string) (UnweaveExec, error)

func (*Queries) ExecGetAllActive 

func (q *Queries) ExecGetAllActive(ctx context.Context) ([]UnweaveExec, error)

func (*Queries) ExecList 

func (q *Queries) ExecList(ctx context.Context, arg ExecListParams) ([]UnweaveExec, error)

func (*Queries) ExecListActiveByProvider 

func (q *Queries) ExecListActiveByProvider(ctx context.Context, provider string) ([]UnweaveExec, error)

func (*Queries) ExecListByProvider 

func (q *Queries) ExecListByProvider(ctx context.Context, provider string) ([]UnweaveExec, error)

func (*Queries) ExecSSHKeyDelete 

func (q *Queries) ExecSSHKeyDelete(ctx context.Context, arg ExecSSHKeyDeleteParams) error

func (*Queries) ExecSSHKeyGet 

func (q *Queries) ExecSSHKeyGet(ctx context.Context, arg ExecSSHKeyGetParams) (UnweaveExecSshKey, error)

func (*Queries) ExecSSHKeyInsert 

func (q *Queries) ExecSSHKeyInsert(ctx context.Context, arg ExecSSHKeyInsertParams) error

func (*Queries) ExecSSHKeysGetByExecID 

func (q *Queries) ExecSSHKeysGetByExecID(ctx context.Context, execID string) ([]UnweaveExecSshKey, error)

func (*Queries) ExecSetError 

func (q *Queries) ExecSetError(ctx context.Context, arg ExecSetErrorParams) error

func (*Queries) ExecSetFailed 

func (q *Queries) ExecSetFailed(ctx context.Context, arg ExecSetFailedParams) error

func (*Queries) ExecStatusUpdate 

func (q *Queries) ExecStatusUpdate(ctx context.Context, arg ExecStatusUpdateParams) error

func (*Queries) ExecUpdateConnectionInfo 

func (q *Queries) ExecUpdateConnectionInfo(ctx context.Context, arg ExecUpdateConnectionInfoParams) error

func (*Queries) ExecUpdateNetwork 

func (q *Queries) ExecUpdateNetwork(ctx context.Context, arg ExecUpdateNetworkParams) error

func (*Queries) ExecVolumeCreate 

func (q *Queries) ExecVolumeCreate(ctx context.Context, arg ExecVolumeCreateParams) error

func (*Queries) ExecVolumeDelete 

func (q *Queries) ExecVolumeDelete(ctx context.Context, execID string) error

func (*Queries) ExecVolumeGet 

func (q *Queries) ExecVolumeGet(ctx context.Context, execID string) ([]UnweaveExecVolume, error)

func (*Queries) MxExecGet 

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

----------------------------------------------------------------- The queries below return data in the format expected by the API. -----------------------------------------------------------------

func (*Queries) MxExecsGet 

func (q *Queries) MxExecsGet(ctx context.Context, projectID string) ([]MxExecsGetRow, error)

func (*Queries) NodeCreate 

func (q *Queries) NodeCreate(ctx context.Context, arg NodeCreateParams) error

func (*Queries) NodeStatusUpdate 

func (q *Queries) NodeStatusUpdate(ctx context.Context, arg NodeStatusUpdateParams) error

func (*Queries) ProjectGet 

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

func (*Queries) SSHKeyAdd 

func (q *Queries) SSHKeyAdd(ctx context.Context, arg SSHKeyAddParams) error

func (*Queries) SSHKeyGetByName 

func (q *Queries) SSHKeyGetByName(ctx context.Context, arg SSHKeyGetByNameParams) (UnweaveSshKey, error)

func (*Queries) SSHKeyGetByPublicKey 

func (q *Queries) SSHKeyGetByPublicKey(ctx context.Context, arg SSHKeyGetByPublicKeyParams) (UnweaveSshKey, error)

func (*Queries) SSHKeysGet 

func (q *Queries) SSHKeysGet(ctx context.Context, ownerID string) ([]UnweaveSshKey, error)

func (*Queries) SSHKeysGetByIDs 

func (q *Queries) SSHKeysGetByIDs(ctx context.Context, ids []string) ([]UnweaveSshKey, error)

func (*Queries) Tx 

func (q *Queries) Tx(txFunc func(db Querier) error) (err error)

func (*Queries) VolumeCreate 

func (q *Queries) VolumeCreate(ctx context.Context, arg VolumeCreateParams) (UnweaveVolume, error)

func (*Queries) VolumeDelete 

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

func (*Queries) VolumeGet 

func (q *Queries) VolumeGet(ctx context.Context, arg VolumeGetParams) (UnweaveVolume, error)

func (*Queries) VolumeList 

func (q *Queries) VolumeList(ctx context.Context, projectID string) ([]UnweaveVolume, error)

func (*Queries) VolumeUpdate 

func (q *Queries) VolumeUpdate(ctx context.Context, arg VolumeUpdateParams) error

type SSHKeyAddParams 

type SSHKeyAddParams struct {
	OwnerID   string `json:"ownerID"`
	Name      string `json:"name"`
	PublicKey string `json:"publicKey"`
}

type SSHKeyGetByNameParams 

type SSHKeyGetByNameParams struct {
	Name    string `json:"name"`
	OwnerID string `json:"ownerID"`
}

type SSHKeyGetByPublicKeyParams 

type SSHKeyGetByPublicKeyParams struct {
	PublicKey string `json:"publicKey"`
	OwnerID   string `json:"ownerID"`
}

type Tx 

type Tx interface {
	Begin() (*sql.Tx, error)
}

type TxQuerier 

type TxQuerier interface {
	Querier
	Txer
}
var Q TxQuerier

Q is a querier for the global database connection

This needs to be initialized when the db connection is first established. It is then safe to use across go routines.

type Txer 

type Txer interface {
	Tx(txFunc func(Querier) error) error
}

type UnweaveAccount 

type UnweaveAccount struct {
	ID string `json:"id"`
}

type UnweaveBuild 

type UnweaveBuild struct {
	ID          string             `json:"id"`
	Name        string             `json:"name"`
	ProjectID   string             `json:"projectID"`
	BuilderType string             `json:"builderType"`
	Status      UnweaveBuildStatus `json:"status"`
	CreatedBy   string             `json:"createdBy"`
	CreatedAt   time.Time          `json:"createdAt"`
	StartedAt   sql.NullTime       `json:"startedAt"`
	FinishedAt  sql.NullTime       `json:"finishedAt"`
	UpdatedAt   time.Time          `json:"updatedAt"`
	MetaData    json.RawMessage    `json:"metaData"`
}

type UnweaveBuildStatus 

type UnweaveBuildStatus string
const (
	UnweaveBuildStatusInitializing    UnweaveBuildStatus = "initializing"
	UnweaveBuildStatusBuilding        UnweaveBuildStatus = "building"
	UnweaveBuildStatusSuccess         UnweaveBuildStatus = "success"
	UnweaveBuildStatusFailed          UnweaveBuildStatus = "failed"
	UnweaveBuildStatusError           UnweaveBuildStatus = "error"
	UnweaveBuildStatusCanceled        UnweaveBuildStatus = "canceled"
	UnweaveBuildStatusSyncingSnapshot UnweaveBuildStatus = "syncing_snapshot"
)

func (*UnweaveBuildStatus) Scan 

func (e *UnweaveBuildStatus) Scan(src interface{}) error

type UnweaveEndpoint 

type UnweaveEndpoint struct {
	ID          string       `json:"id"`
	Name        string       `json:"name"`
	Icon        string       `json:"icon"`
	ProjectID   string       `json:"projectID"`
	HttpAddress string       `json:"httpAddress"`
	CreatedAt   time.Time    `json:"createdAt"`
	DeletedAt   sql.NullTime `json:"deletedAt"`
}

type UnweaveEndpointCheck 

type UnweaveEndpointCheck struct {
	ID         string    `json:"id"`
	EndpointID string    `json:"endpointID"`
	ProjectID  string    `json:"projectID"`
	CreatedAt  time.Time `json:"createdAt"`
}

type UnweaveEndpointCheckStep 

type UnweaveEndpointCheckStep struct {
	ID        string         `json:"id"`
	CheckID   string         `json:"checkID"`
	EvalID    string         `json:"evalID"`
	Input     sql.NullString `json:"input"`
	Output    sql.NullString `json:"output"`
	Assertion sql.NullString `json:"assertion"`
}

type UnweaveEndpointEval 

type UnweaveEndpointEval struct {
	EndpointID string `json:"endpointID"`
	EvalID     string `json:"evalID"`
}

type UnweaveEndpointVersion 

type UnweaveEndpointVersion struct {
	ID             string       `json:"id"`
	EndpointID     string       `json:"endpointID"`
	ExecID         string       `json:"execID"`
	ProjectID      string       `json:"projectID"`
	HttpAddress    string       `json:"httpAddress"`
	PrimaryVersion bool         `json:"primaryVersion"`
	CreatedAt      time.Time    `json:"createdAt"`
	DeletedAt      sql.NullTime `json:"deletedAt"`
}

type UnweaveEval 

type UnweaveEval struct {
	ID          string    `json:"id"`
	ExecID      string    `json:"execID"`
	ProjectID   string    `json:"projectID"`
	HttpAddress string    `json:"httpAddress"`
	CreatedAt   time.Time `json:"createdAt"`
}

type UnweaveExec 

type UnweaveExec struct {
	ID           string            `json:"id"`
	Name         string            `json:"name"`
	Region       string            `json:"region"`
	CreatedBy    string            `json:"createdBy"`
	CreatedAt    time.Time         `json:"createdAt"`
	ReadyAt      sql.NullTime      `json:"readyAt"`
	ExitedAt     sql.NullTime      `json:"exitedAt"`
	Status       UnweaveExecStatus `json:"status"`
	ProjectID    string            `json:"projectID"`
	Error        sql.NullString    `json:"error"`
	BuildID      sql.NullString    `json:"buildID"`
	Spec         json.RawMessage   `json:"spec"`
	CommitID     sql.NullString    `json:"commitID"`
	GitRemoteUrl sql.NullString    `json:"gitRemoteUrl"`
	Command      []string          `json:"command"`
	Metadata     json.RawMessage   `json:"metadata"`
	Image        string            `json:"image"`
	Provider     string            `json:"provider"`
}

type UnweaveExecSshKey 

type UnweaveExecSshKey struct {
	ExecID   string `json:"execID"`
	SshKeyID string `json:"sshKeyID"`
}

type UnweaveExecStatus 

type UnweaveExecStatus string
const (
	UnweaveExecStatusInitializing UnweaveExecStatus = "initializing"
	UnweaveExecStatusRunning      UnweaveExecStatus = "running"
	UnweaveExecStatusTerminated   UnweaveExecStatus = "terminated"
	UnweaveExecStatusError        UnweaveExecStatus = "error"
	UnweaveExecStatusSnapshotting UnweaveExecStatus = "snapshotting"
	UnweaveExecStatusPending      UnweaveExecStatus = "pending"
)

func (*UnweaveExecStatus) Scan 

func (e *UnweaveExecStatus) Scan(src interface{}) error

type UnweaveExecVolume 

type UnweaveExecVolume struct {
	ExecID    string `json:"execID"`
	VolumeID  string `json:"volumeID"`
	MountPath string `json:"mountPath"`
}

type UnweaveNode 

type UnweaveNode struct {
	ID           string          `json:"id"`
	Provider     string          `json:"provider"`
	Region       string          `json:"region"`
	Metadata     json.RawMessage `json:"metadata"`
	Status       string          `json:"status"`
	CreatedAt    time.Time       `json:"createdAt"`
	ReadyAt      sql.NullTime    `json:"readyAt"`
	OwnerID      string          `json:"ownerID"`
	TerminatedAt sql.NullTime    `json:"terminatedAt"`
}

type UnweaveNodeSshKey 

type UnweaveNodeSshKey struct {
	NodeID    string    `json:"nodeID"`
	SshKeyID  string    `json:"sshKeyID"`
	CreatedAt time.Time `json:"createdAt"`
}

type UnweaveProject 

type UnweaveProject struct {
	ID             string         `json:"id"`
	DefaultBuildID sql.NullString `json:"defaultBuildID"`
}

type UnweaveSshKey 

type UnweaveSshKey struct {
	ID        string    `json:"id"`
	Name      string    `json:"name"`
	OwnerID   string    `json:"ownerID"`
	CreatedAt time.Time `json:"createdAt"`
	PublicKey string    `json:"publicKey"`
	IsActive  bool      `json:"isActive"`
}

type UnweaveVolume 

type UnweaveVolume struct {
	ID        string       `json:"id"`
	Size      int32        `json:"size"`
	Name      string       `json:"name"`
	ProjectID string       `json:"projectID"`
	Provider  string       `json:"provider"`
	CreatedAt time.Time    `json:"createdAt"`
	UpdatedAt time.Time    `json:"updatedAt"`
	DeletedAt sql.NullTime `json:"deletedAt"`
}

type VolumeCreateParams 

type VolumeCreateParams struct {
	ID        string `json:"id"`
	ProjectID string `json:"projectID"`
	Provider  string `json:"provider"`
	Name      string `json:"name"`
	Size      int32  `json:"size"`
}

type VolumeGetParams 

type VolumeGetParams struct {
	ProjectID string `json:"projectID"`
	ID        string `json:"id"`
}

type VolumeUpdateParams 

type VolumeUpdateParams struct {
	ID   string `json:"id"`
	Size int32  `json:"size"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.