Documentation
¶
Index ¶
- Variables
- type AllChunkThumbnailHashesRow
- type Blob
- type BuildStatus
- 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 CreateUserParams
- 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 ListFlavorsByChunkIDRow
- type ListInstancesRow
- type MinecraftVersion
- type Node
- type NullBuildStatus
- type NullInstanceState
- type NullRiverJobState
- type Queries
- func (q *Queries) AllChunkThumbnailHashes(ctx context.Context) ([]AllChunkThumbnailHashesRow, error)
- func (q *Queries) AllMinecraftVersions(ctx context.Context) ([]string, error)
- 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) ChunkOwnerByChunkID(ctx context.Context, id string) (User, error)
- func (q *Queries) ChunkOwnerByFlavorID(ctx context.Context, id string) (User, error)
- func (q *Queries) ChunkOwnerByFlavorVersionID(ctx context.Context, id string) (User, 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) CreateUser(ctx context.Context, arg CreateUserParams) error
- func (q *Queries) FlavorNameExists(ctx context.Context, arg FlavorNameExistsParams) (bool, 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) ([]ListFlavorsByChunkIDRow, error)
- func (q *Queries) ListInstances(ctx context.Context) ([]ListInstancesRow, error)
- func (q *Queries) MarkFlavorVersionFilesUploaded(ctx context.Context, id string) error
- func (q *Queries) MinecraftVersionExists(ctx context.Context, version string) (bool, error)
- func (q *Queries) RandomNode(ctx context.Context) (Node, error)
- func (q *Queries) UpdateChunk(ctx context.Context, arg UpdateChunkParams) error
- func (q *Queries) UpdateChunkThumbnail(ctx context.Context, arg UpdateChunkThumbnailParams) error
- func (q *Queries) UpdateFlavorVersionBuildStatus(ctx context.Context, arg UpdateFlavorVersionBuildStatusParams) error
- func (q *Queries) UpdateFlavorVersionPresignedURLData(ctx context.Context, arg UpdateFlavorVersionPresignedURLDataParams) error
- func (q *Queries) UserByEmail(ctx context.Context, email string) (User, error)
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type RiverClient
- type RiverClientQueue
- type RiverJob
- type RiverJobState
- type RiverLeader
- type RiverQueue
- type SchemaMigration
- type UpdateChunkParams
- type UpdateChunkThumbnailParams
- type UpdateFlavorVersionBuildStatusParams
- type UpdateFlavorVersionPresignedURLDataParams
- type User
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrBatchAlreadyClosed = errors.New("batch already closed")
)
Functions ¶
This section is empty.
Types ¶
type BuildStatus ¶
type BuildStatus string
const ( BuildStatusPENDING BuildStatus = "PENDING" BuildStatusIMAGEBUILD BuildStatus = "IMAGE_BUILD" BuildStatusIMAGEBUILDFAILED BuildStatus = "IMAGE_BUILD_FAILED" BuildStatusCHECKPOINTBUILD BuildStatus = "CHECKPOINT_BUILD" BuildStatusCHECKPOINTBUILDFAILED BuildStatus = "CHECKPOINT_BUILD_FAILED" BuildStatusCOMPLETED BuildStatus = "COMPLETED" )
func (*BuildStatus) Scan ¶
func (e *BuildStatus) Scan(src interface{}) error
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
ID string
}
type CreateChunkParams ¶
type CreateFlavorParams ¶
type CreateInstanceParams ¶
type CreateUserParams ¶
type FlavorNameExistsParams ¶
type FlavorVersion ¶
type FlavorVersionByIDRow ¶
type FlavorVersionByIDRow struct {
ID string
FlavorID string
Hash string
ChangeHash string
BuildStatus BuildStatus
Version string
FilesUploaded bool
PrevVersionID *string
CreatedAt time.Time
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
MinecraftVersion string
FlavorVersionID string
FileHash string
FilePath string
CreatedAt_2 time.Time
}
type FlavorVersionFile ¶
type GetChunkByIDRow ¶
type GetChunkByIDRow struct {
ID string
Name string
Description string
Tags []string
CreatedAt time.Time
UpdatedAt time.Time
OwnerID string
ThumbnailHash pgtype.Text
ThumbnailUpdatedAt time.Time
ID_2 *string
ChunkID *string
Name_2 pgtype.Text
CreatedAt_2 pgtype.Timestamptz
UpdatedAt_2 pgtype.Timestamptz
ID_3 *string
FlavorID *string
Hash pgtype.Text
ChangeHash pgtype.Text
BuildStatus NullBuildStatus
Version pgtype.Text
FilesUploaded pgtype.Bool
PrevVersionID *string
CreatedAt_3 pgtype.Timestamptz
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
MinecraftVersion pgtype.Text
FlavorVersionID *string
FileHash pgtype.Text
FilePath pgtype.Text
CreatedAt_4 pgtype.Timestamptz
ID_4 *string
Nickname pgtype.Text
Email pgtype.Text
CreatedAt_5 pgtype.Timestamptz
UpdatedAt_3 pgtype.Timestamptz
}
type GetInstanceRow ¶
type GetInstanceRow struct {
ID string
ChunkID string
FlavorVersionID string
NodeID string
Port *int32
State InstanceState
CreatedAt time.Time
UpdatedAt time.Time
OwnerID string
ID_2 string
FlavorID string
Hash string
ChangeHash string
BuildStatus BuildStatus
Version string
FilesUploaded bool
PrevVersionID *string
CreatedAt_2 time.Time
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
MinecraftVersion string
ID_3 string
Name string
Description string
Tags []string
CreatedAt_3 time.Time
UpdatedAt_2 time.Time
OwnerID_2 string
ThumbnailHash pgtype.Text
ThumbnailUpdatedAt time.Time
ID_4 string
ChunkID_2 string
Name_2 string
CreatedAt_4 time.Time
UpdatedAt_3 time.Time
ID_5 string
Name_3 string
Address netip.Addr
CheckpointApiEndpoint string
CreatedAt_5 time.Time
ID_6 string
Nickname string
Email string
CreatedAt_6 time.Time
UpdatedAt_4 time.Time
}
type GetInstancesByNodeIDRow ¶
type GetInstancesByNodeIDRow struct {
ID string
ChunkID string
FlavorVersionID string
NodeID string
Port *int32
State InstanceState
CreatedAt time.Time
UpdatedAt time.Time
OwnerID string
ID_2 string
FlavorID string
Hash string
ChangeHash string
BuildStatus BuildStatus
Version string
FilesUploaded bool
PrevVersionID *string
CreatedAt_2 time.Time
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
MinecraftVersion string
ID_3 string
Name string
Description string
Tags []string
CreatedAt_3 time.Time
UpdatedAt_2 time.Time
OwnerID_2 string
ThumbnailHash pgtype.Text
ThumbnailUpdatedAt time.Time
ID_4 string
Name_2 string
Address netip.Addr
CheckpointApiEndpoint string
CreatedAt_4 time.Time
ID_5 string
Nickname string
Email string
CreatedAt_5 time.Time
UpdatedAt_3 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 ListChunksRow struct {
ID string
Name string
Description string
Tags []string
CreatedAt time.Time
UpdatedAt time.Time
OwnerID string
ThumbnailHash pgtype.Text
ThumbnailUpdatedAt time.Time
ID_2 *string
ChunkID *string
Name_2 pgtype.Text
CreatedAt_2 pgtype.Timestamptz
UpdatedAt_2 pgtype.Timestamptz
ID_3 *string
FlavorID *string
Hash pgtype.Text
ChangeHash pgtype.Text
BuildStatus NullBuildStatus
Version pgtype.Text
FilesUploaded pgtype.Bool
PrevVersionID *string
CreatedAt_3 pgtype.Timestamptz
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
MinecraftVersion pgtype.Text
FlavorVersionID *string
FileHash pgtype.Text
FilePath pgtype.Text
CreatedAt_4 pgtype.Timestamptz
ID_4 *string
Nickname pgtype.Text
Email pgtype.Text
CreatedAt_5 pgtype.Timestamptz
UpdatedAt_3 pgtype.Timestamptz
}
type ListFlavorsByChunkIDRow ¶
type ListFlavorsByChunkIDRow struct {
ID string
ChunkID string
Name string
CreatedAt time.Time
UpdatedAt time.Time
ID_2 string
FlavorID string
Hash string
ChangeHash string
BuildStatus BuildStatus
Version string
FilesUploaded bool
PrevVersionID *string
CreatedAt_2 time.Time
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
MinecraftVersion string
FlavorVersionID string
FileHash string
FilePath string
CreatedAt_3 time.Time
}
type ListInstancesRow ¶
type ListInstancesRow struct {
ID string
ChunkID string
FlavorVersionID string
NodeID string
Port *int32
State InstanceState
CreatedAt time.Time
UpdatedAt time.Time
OwnerID string
ID_2 string
FlavorID string
Hash string
ChangeHash string
BuildStatus BuildStatus
Version string
FilesUploaded bool
PrevVersionID *string
CreatedAt_2 time.Time
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
MinecraftVersion string
ID_3 string
Name string
Description string
Tags []string
CreatedAt_3 time.Time
UpdatedAt_2 time.Time
OwnerID_2 string
ThumbnailHash pgtype.Text
ThumbnailUpdatedAt time.Time
ID_4 string
ChunkID_2 string
Name_2 string
CreatedAt_4 time.Time
UpdatedAt_3 time.Time
ID_5 string
Name_3 string
Address netip.Addr
CheckpointApiEndpoint string
CreatedAt_5 time.Time
ID_6 string
Nickname string
Email string
CreatedAt_6 time.Time
UpdatedAt_4 time.Time
}
type MinecraftVersion ¶
type MinecraftVersion struct {
Version string
CreatedAt pgtype.Timestamptz
}
type NullBuildStatus ¶
type NullBuildStatus struct {
BuildStatus BuildStatus
Valid bool // Valid is true if BuildStatus is not NULL
}
func (*NullBuildStatus) Scan ¶
func (ns *NullBuildStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
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 NullRiverJobState ¶
type NullRiverJobState struct {
RiverJobState RiverJobState
Valid bool // Valid is true if RiverJobState is not NULL
}
func (*NullRiverJobState) Scan ¶
func (ns *NullRiverJobState) Scan(value interface{}) error
Scan implements the Scanner interface.
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AllChunkThumbnailHashes ¶
func (q *Queries) AllChunkThumbnailHashes(ctx context.Context) ([]AllChunkThumbnailHashesRow, error)
func (*Queries) AllMinecraftVersions ¶
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) ChunkOwnerByChunkID ¶
func (*Queries) ChunkOwnerByFlavorID ¶
func (*Queries) ChunkOwnerByFlavorVersionID ¶
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) CreateUser ¶
func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) error
func (*Queries) FlavorNameExists ¶
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) MinecraftVersionExists ¶
func (*Queries) UpdateChunk ¶
func (q *Queries) UpdateChunk(ctx context.Context, arg UpdateChunkParams) error
func (*Queries) UpdateChunkThumbnail ¶
func (q *Queries) UpdateChunkThumbnail(ctx context.Context, arg UpdateChunkThumbnailParams) error
func (*Queries) UpdateFlavorVersionBuildStatus ¶
func (q *Queries) UpdateFlavorVersionBuildStatus(ctx context.Context, arg UpdateFlavorVersionBuildStatusParams) error
func (*Queries) UpdateFlavorVersionPresignedURLData ¶
func (q *Queries) UpdateFlavorVersionPresignedURLData(ctx context.Context, arg UpdateFlavorVersionPresignedURLDataParams) error
func (*Queries) UserByEmail ¶
type RiverClient ¶
type RiverClientQueue ¶
type RiverJob ¶
type RiverJob struct {
ID int64
State RiverJobState
Attempt int16
MaxAttempts int16
AttemptedAt pgtype.Timestamptz
CreatedAt time.Time
FinalizedAt pgtype.Timestamptz
ScheduledAt time.Time
Priority int16
Args []byte
AttemptedBy []string
Errors [][]byte
Kind string
Metadata []byte
Queue string
Tags []string
UniqueKey []byte
UniqueStates pgtype.Bits
}
type RiverJobState ¶
type RiverJobState string
const ( RiverJobStateAvailable RiverJobState = "available" RiverJobStateCancelled RiverJobState = "cancelled" RiverJobStateCompleted RiverJobState = "completed" RiverJobStateDiscarded RiverJobState = "discarded" RiverJobStatePending RiverJobState = "pending" RiverJobStateRetryable RiverJobState = "retryable" RiverJobStateRunning RiverJobState = "running" RiverJobStateScheduled RiverJobState = "scheduled" )
func (*RiverJobState) Scan ¶
func (e *RiverJobState) Scan(src interface{}) error
type RiverLeader ¶
type RiverQueue ¶
type SchemaMigration ¶
type SchemaMigration struct {
Version string
}
type UpdateChunkParams ¶
type UpdateFlavorVersionBuildStatusParams ¶
type UpdateFlavorVersionBuildStatusParams struct {
BuildStatus BuildStatus
ID string
}
type UpdateFlavorVersionPresignedURLDataParams ¶
type UpdateFlavorVersionPresignedURLDataParams struct {
PresignedUrlExpiryDate pgtype.Timestamptz
PresignedUrl pgtype.Text
ID string
}
Click to show internal directories.
Click to hide internal directories.