db

type AppendAuditParams struct {
	Actor   string
	Action  string
	Subject string
	Details []byte
}

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

type AppendEventParams struct {
	TaskID  string
	Seq     int64
	Kind    string
	Ts      time.Time
	Payload []byte
}

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

type AppendLogChunkParams struct {
	TaskID       string
	Seq          int64
	Stream       string
	Sidecar      *string
	Ts           time.Time
	Bytes        []byte
	SourceOffset int64
}

type Artifact struct {
	ID          string
	TaskID      string
	Kind        string
	Name        string
	ObjectKey   string
	SizeBytes   int64
	ContentType string
	Sha256      string
	CreatedAt   time.Time
}

type AssignTaskParams struct {
	NodeID         *string
	LeaseID        *string
	LeaseExpiresAt *time.Time
	ID             string
}

type AuditLog struct {
	ID      int64
	Ts      time.Time
	Actor   string
	Action  string
	Subject string
	Details []byte
}

type ConsumeEnrollmentTokenParams struct {
	UsedByNodeID *string
	TokenHash    []byte
}

type CreateArtifactParams struct {
	ID          string
	TaskID      string
	Kind        string
	Name        string
	ObjectKey   string
	SizeBytes   int64
	ContentType string
	Sha256      string
}

type CreateEnrollmentTokenParams struct {
	ID        string
	TokenHash []byte
	Labels    []byte
	ExpiresAt time.Time
	CreatedBy string
}

type CreateNodeParams struct {
	ID          string
	Name        string
	Tags        []string
	Labels      []byte
	Capacity    []byte
	NodeKeyHash []byte
	Status      string
	Version     *string
	TsStableID  *string
}

type CreateSessionParams struct {
	ID        string
	TokenHash []byte
	Login     string
	ExpiresAt time.Time
}

type CreateTaskParams struct {
	ID          string
	Spec        []byte
	Status      string
	Priority    int32
	RequestedBy string
	MaxAttempts int32
}

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}

type EnrollmentToken struct {
	ID           string
	TokenHash    []byte
	Labels       []byte
	ExpiresAt    time.Time
	UsedAt       *time.Time
	UsedByNodeID *string
	CreatedBy    string
	CreatedAt    time.Time
}

type ExtendLeaseParams struct {
	LeaseExpiresAt *time.Time
	ID             string
	LeaseID        *string
}

type InsertInstanceParams struct {
	HostedDomain string
	ClaimedBy    string
}

type Instance struct {
	ID           int32
	HostedDomain string
	ClaimedBy    string
	ClaimedAt    time.Time
}

type ListArtifactsByKindParams struct {
	TaskID string
	Kind   string
}

type ListAuditParams struct {
	Action   string
	Subject  string
	RowLimit int32
}

type ListEventsParams struct {
	TaskID    string
	FromSeq   int64
	PageLimit int32
}

type ListLogChunksParams struct {
	TaskID    string
	FromSeq   int64
	PageLimit int32
}

type ListTasksOnNodeParams struct {
	NodeID   *string
	Statuses []string
}

type ListTasksParams struct {
	Statuses      []string
	NodeID        string
	RequestedBy   string
	Search        string
	CreatedAfter  *time.Time
	CreatedBefore *time.Time
	AfterID       string
	PageLimit     int32
}

type MarkLogsRolledUpParams struct {
	HighSeq      int64
	StdoutOffset int64
	StderrOffset int64
	ID           string
}

type MarkScheduleAttemptParams struct {
	QueuedReason string
	ID           string
}

type Node struct {
	ID               string
	Name             string
	Tags             []string
	Labels           []byte
	Capacity         []byte
	NodeKeyHash      []byte
	Status           string
	Version          *string
	LastHeartbeatAt  *time.Time
	CreatedAt        time.Time
	TsStableID       *string
	Draining         bool
	MaxTasksOverride *int32
}

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

type ReEncryptRegistryParams struct {
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	Host       string
}

type ReEncryptSecretParams struct {
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	Name       string
}

type Registry struct {
	Host       string
	Username   string
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	CreatedBy  string
	UpdatedAt  time.Time
}

type RequestCancelParams struct {
	CancelReason string
	CancelStatus string
	ID           string
}

type Secret struct {
	Name       string
	Ciphertext []byte
	Nonce      []byte
	Version    int32
	KeyID      string
	CreatedBy  string
	UpdatedAt  time.Time
}

type Session struct {
	ID        string
	TokenHash []byte
	Login     string
	ExpiresAt time.Time
	CreatedAt time.Time
}

type SetNodeDrainingParams struct {
	Draining bool
	ID       string
}

type SetNodeLabelsParams struct {
	Labels []byte
	ID     string
}

type SetNodeMaxTasksParams struct {
	MaxTasksOverride *int32
	ID               string
}

type SetNodeStatusParams struct {
	Status string
	ID     string
}

type SetNodeTSStableIDParams struct {
	TsStableID *string
	ID         string
}

type SetUserRolesParams struct {
	Roles []string
	Login string
}

type Task struct {
	ID                    string
	Spec                  []byte
	Status                string
	Priority              int32
	RequestedBy           string
	NodeID                *string
	LeaseID               *string
	LeaseExpiresAt        *time.Time
	Attempts              int32
	MaxAttempts           int32
	CreatedAt             time.Time
	ScheduledAt           *time.Time
	StartedAt             *time.Time
	FinishedAt            *time.Time
	ExitCode              *int32
	Usage                 []byte
	FailureReason         *string
	LastScheduleAttemptAt *time.Time
	QueuedReason          *string
	CancelRequestedAt     *time.Time
	CancelReason          *string
	CancelStatus          *string
	LogsRolledUpAt        *time.Time
	LogsHighSeq           int64
	LogsStdoutOffset      int64
	LogsStderrOffset      int64
}

type TaskEvent struct {
	TaskID  string
	Seq     int64
	Kind    string
	Ts      time.Time
	Payload []byte
}

type TaskLogChunk struct {
	TaskID       string
	Seq          int64
	Stream       string
	Sidecar      *string
	Ts           time.Time
	Bytes        []byte
	SourceOffset int64
}

type TaskLogRollUpRow struct {
	LogsRolledUpAt   *time.Time
	LogsHighSeq      int64
	LogsStdoutOffset int64
	LogsStderrOffset int64
}

type TaskStreamOffsetsRow struct {
	StdoutOffset int64
	StderrOffset int64
}

type TasksPendingLogRollUpParams struct {
	FinishedBefore time.Time
	PageLimit      int32
}

type UpdateNodeHeartbeatParams struct {
	Status   string
	Capacity []byte
	Version  *string
	ID       string
}

type UpdateTaskTransitionParams struct {
	ToStatus       string
	StartedAt      *time.Time
	FinishedAt     *time.Time
	ExitCode       *int32
	Usage          []byte
	FailureReason  *string
	NodeID         *string
	LeaseID        *string
	LeaseExpiresAt *time.Time
	ID             string
}

type UpsertRegistryParams struct {
	Host       string
	Username   string
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	CreatedBy  string
}

type UpsertSecretParams struct {
	Name       string
	Ciphertext []byte
	Nonce      []byte
	KeyID      string
	CreatedBy  string
}

type UpsertUserParams struct {
	Login        string
	DisplayName  *string
	HostedDomain *string
	PictureUrl   *string
}

type User struct {
	Login        string
	DisplayName  *string
	Roles        []string
	FirstSeenAt  time.Time
	HostedDomain *string
	PictureUrl   *string
}