Documentation
¶
Index ¶
- Variables
- type Blob
- type BulkDeleteInstancesBatchResults
- type BulkGetBlobDataBatchResults
- type BulkInsertBlobDataBatchResults
- type BulkInsertBlobDataParams
- type BulkInsertFlavorFileHashesBatchResults
- type BulkInsertFlavorFileHashesParams
- type BulkUpdateInstanceStateAndPortBatchResults
- type BulkUpdateInstanceStateAndPortParams
- type Chunk
- type CreateChunkParams
- type CreateFlavorParams
- type CreateFlavorVersionParams
- type CreateInstanceParams
- type DBTX
- type Flavor
- type FlavorNameExistsParams
- type FlavorVersion
- type FlavorVersionByIDRow
- type FlavorVersionExistsParams
- type FlavorVersionFile
- type GetChunkByIDRow
- type GetInstanceRow
- type GetInstancesByNodeIDRow
- type Instance
- type InstanceState
- type ListChunksRow
- type ListInstancesRow
- type Node
- type NullInstanceState
- type Queries
- func (q *Queries) BulkDeleteInstances(ctx context.Context, id []string) *BulkDeleteInstancesBatchResults
- func (q *Queries) BulkGetBlobData(ctx context.Context, hash []string) *BulkGetBlobDataBatchResults
- func (q *Queries) BulkInsertBlobData(ctx context.Context, arg []BulkInsertBlobDataParams) *BulkInsertBlobDataBatchResults
- func (q *Queries) BulkInsertFlavorFileHashes(ctx context.Context, arg []BulkInsertFlavorFileHashesParams) *BulkInsertFlavorFileHashesBatchResults
- func (q *Queries) BulkUpdateInstanceStateAndPort(ctx context.Context, arg []BulkUpdateInstanceStateAndPortParams) *BulkUpdateInstanceStateAndPortBatchResults
- func (q *Queries) ChunkExists(ctx context.Context, id string) (bool, error)
- func (q *Queries) CreateChunk(ctx context.Context, arg CreateChunkParams) error
- func (q *Queries) CreateFlavor(ctx context.Context, arg CreateFlavorParams) error
- func (q *Queries) CreateFlavorVersion(ctx context.Context, arg CreateFlavorVersionParams) error
- func (q *Queries) CreateInstance(ctx context.Context, arg CreateInstanceParams) error
- func (q *Queries) FlavorNameExists(ctx context.Context, arg FlavorNameExistsParams) (bool, error)
- func (q *Queries) FlavorVersionByHash(ctx context.Context, hash string) (string, error)
- func (q *Queries) FlavorVersionByID(ctx context.Context, id string) ([]FlavorVersionByIDRow, error)
- func (q *Queries) FlavorVersionExists(ctx context.Context, arg FlavorVersionExistsParams) (bool, error)
- func (q *Queries) FlavorVersionFileHashes(ctx context.Context, flavorVersionID string) ([]FlavorVersionFile, error)
- func (q *Queries) FlavorVersionHashByID(ctx context.Context, id string) (string, error)
- func (q *Queries) GetChunkByID(ctx context.Context, id string) ([]GetChunkByIDRow, error)
- func (q *Queries) GetInstance(ctx context.Context, id string) ([]GetInstanceRow, error)
- func (q *Queries) GetInstancesByNodeID(ctx context.Context, nodeID string) ([]GetInstancesByNodeIDRow, error)
- func (q *Queries) LatestFlavorVersionByFlavorID(ctx context.Context, flavorID string) (FlavorVersion, error)
- func (q *Queries) ListChunks(ctx context.Context) ([]ListChunksRow, error)
- func (q *Queries) ListFlavorsByChunkID(ctx context.Context, chunkID string) ([]Flavor, error)
- func (q *Queries) ListInstances(ctx context.Context) ([]ListInstancesRow, error)
- func (q *Queries) MarkFlavorVersionFilesUploaded(ctx context.Context, id string) error
- func (q *Queries) UpdateChunk(ctx context.Context, arg UpdateChunkParams) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type SchemaMigration
- type UpdateChunkParams
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrBatchAlreadyClosed = errors.New("batch already closed")
)
Functions ¶
This section is empty.
Types ¶
type BulkDeleteInstancesBatchResults ¶
type BulkDeleteInstancesBatchResults struct {
// contains filtered or unexported fields
}
func (*BulkDeleteInstancesBatchResults) Close ¶
func (b *BulkDeleteInstancesBatchResults) Close() error
func (*BulkDeleteInstancesBatchResults) Exec ¶
func (b *BulkDeleteInstancesBatchResults) Exec(f func(int, error))
type BulkGetBlobDataBatchResults ¶
type BulkGetBlobDataBatchResults struct {
// contains filtered or unexported fields
}
func (*BulkGetBlobDataBatchResults) Close ¶
func (b *BulkGetBlobDataBatchResults) Close() error
type BulkInsertBlobDataBatchResults ¶
type BulkInsertBlobDataBatchResults struct {
// contains filtered or unexported fields
}
func (*BulkInsertBlobDataBatchResults) Close ¶
func (b *BulkInsertBlobDataBatchResults) Close() error
func (*BulkInsertBlobDataBatchResults) Exec ¶
func (b *BulkInsertBlobDataBatchResults) Exec(f func(int, error))
type BulkInsertFlavorFileHashesBatchResults ¶
type BulkInsertFlavorFileHashesBatchResults struct {
// contains filtered or unexported fields
}
func (*BulkInsertFlavorFileHashesBatchResults) Close ¶
func (b *BulkInsertFlavorFileHashesBatchResults) Close() error
func (*BulkInsertFlavorFileHashesBatchResults) Exec ¶
func (b *BulkInsertFlavorFileHashesBatchResults) Exec(f func(int, error))
type BulkUpdateInstanceStateAndPortBatchResults ¶
type BulkUpdateInstanceStateAndPortBatchResults struct {
// contains filtered or unexported fields
}
func (*BulkUpdateInstanceStateAndPortBatchResults) Close ¶
func (b *BulkUpdateInstanceStateAndPortBatchResults) Close() error
func (*BulkUpdateInstanceStateAndPortBatchResults) Exec ¶
func (b *BulkUpdateInstanceStateAndPortBatchResults) Exec(f func(int, error))
type BulkUpdateInstanceStateAndPortParams ¶
type BulkUpdateInstanceStateAndPortParams struct { State InstanceState Port *int32 }
type CreateChunkParams ¶
type CreateFlavorParams ¶
type CreateInstanceParams ¶
type FlavorNameExistsParams ¶
type FlavorVersion ¶
type FlavorVersionByIDRow ¶
type FlavorVersionFile ¶
type GetChunkByIDRow ¶
type GetInstanceRow ¶
type GetInstanceRow struct { ID string ChunkID string FlavorID string NodeID string Port *int32 State InstanceState CreatedAt time.Time UpdatedAt time.Time ID_2 string ChunkID_2 string Name string CreatedAt_2 time.Time UpdatedAt_2 time.Time ID_3 string Name_2 string Description string Tags []string CreatedAt_3 time.Time UpdatedAt_3 time.Time ID_4 string Address netip.Addr CreatedAt_4 time.Time }
type GetInstancesByNodeIDRow ¶
type GetInstancesByNodeIDRow struct { ID string ChunkID string FlavorID string NodeID string Port *int32 State InstanceState CreatedAt time.Time UpdatedAt time.Time ID_2 string ChunkID_2 string Name string CreatedAt_2 time.Time UpdatedAt_2 time.Time ID_3 string Name_2 string Description string Tags []string CreatedAt_3 time.Time UpdatedAt_3 time.Time ID_4 string Address netip.Addr CreatedAt_4 time.Time }
type InstanceState ¶
type InstanceState string
const ( InstanceStatePENDING InstanceState = "PENDING" InstanceStateCREATING InstanceState = "CREATING" InstanceStateRUNNING InstanceState = "RUNNING" InstanceStateDELETING InstanceState = "DELETING" InstanceStateDELETED InstanceState = "DELETED" InstanceStateCREATIONFAILED InstanceState = "CREATION_FAILED" )
func (*InstanceState) Scan ¶
func (e *InstanceState) Scan(src interface{}) error
type ListChunksRow ¶
type ListInstancesRow ¶
type ListInstancesRow struct { ID string ChunkID string FlavorID string NodeID string Port *int32 State InstanceState CreatedAt time.Time UpdatedAt time.Time ID_2 string ChunkID_2 string Name string CreatedAt_2 time.Time UpdatedAt_2 time.Time ID_3 string Name_2 string Description string Tags []string CreatedAt_3 time.Time UpdatedAt_3 time.Time ID_4 string Address netip.Addr CreatedAt_4 time.Time }
type NullInstanceState ¶
type NullInstanceState struct { InstanceState InstanceState Valid bool // Valid is true if InstanceState is not NULL }
func (*NullInstanceState) Scan ¶
func (ns *NullInstanceState) Scan(value interface{}) error
Scan implements the Scanner interface.
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) BulkDeleteInstances ¶
func (q *Queries) BulkDeleteInstances(ctx context.Context, id []string) *BulkDeleteInstancesBatchResults
func (*Queries) BulkGetBlobData ¶
func (q *Queries) BulkGetBlobData(ctx context.Context, hash []string) *BulkGetBlobDataBatchResults
func (*Queries) BulkInsertBlobData ¶
func (q *Queries) BulkInsertBlobData(ctx context.Context, arg []BulkInsertBlobDataParams) *BulkInsertBlobDataBatchResults
func (*Queries) BulkInsertFlavorFileHashes ¶
func (q *Queries) BulkInsertFlavorFileHashes(ctx context.Context, arg []BulkInsertFlavorFileHashesParams) *BulkInsertFlavorFileHashesBatchResults
func (*Queries) BulkUpdateInstanceStateAndPort ¶
func (q *Queries) BulkUpdateInstanceStateAndPort(ctx context.Context, arg []BulkUpdateInstanceStateAndPortParams) *BulkUpdateInstanceStateAndPortBatchResults
func (*Queries) ChunkExists ¶
func (*Queries) CreateChunk ¶
func (q *Queries) CreateChunk(ctx context.Context, arg CreateChunkParams) error
func (*Queries) CreateFlavor ¶
func (q *Queries) CreateFlavor(ctx context.Context, arg CreateFlavorParams) error
TODO: insert multiple (aka :batchmany)
func (*Queries) CreateFlavorVersion ¶
func (q *Queries) CreateFlavorVersion(ctx context.Context, arg CreateFlavorVersionParams) error
func (*Queries) CreateInstance ¶
func (q *Queries) CreateInstance(ctx context.Context, arg CreateInstanceParams) error
func (*Queries) FlavorNameExists ¶
func (*Queries) FlavorVersionByHash ¶
func (*Queries) FlavorVersionByID ¶
func (*Queries) FlavorVersionExists ¶
func (*Queries) FlavorVersionFileHashes ¶
func (*Queries) FlavorVersionHashByID ¶
func (*Queries) GetChunkByID ¶
TODO: read multiple
func (*Queries) GetInstance ¶
func (*Queries) GetInstancesByNodeID ¶
func (*Queries) LatestFlavorVersionByFlavorID ¶
func (*Queries) ListChunks ¶
func (q *Queries) ListChunks(ctx context.Context) ([]ListChunksRow, error)
func (*Queries) ListFlavorsByChunkID ¶
func (*Queries) ListInstances ¶
func (q *Queries) ListInstances(ctx context.Context) ([]ListInstancesRow, error)
func (*Queries) MarkFlavorVersionFilesUploaded ¶
func (*Queries) UpdateChunk ¶
func (q *Queries) UpdateChunk(ctx context.Context, arg UpdateChunkParams) error
type SchemaMigration ¶
type SchemaMigration struct {
Version string
}
Click to show internal directories.
Click to hide internal directories.