db

type Analytics interface {
	QueryTopResultsByKey(ctx context.Context, arg QueryTopResultsByKeyParams) ([]QueryTopResultsByKeyRow, error)
	CreateResultMetadata(ctx context.Context, arg CreateResultMetadataParams) error
	CountQueryTopResultsByKey(ctx context.Context, key string) (int64, error)
	QueryMostRecentResultsByKey(ctx context.Context, arg QueryMostRecentResultsByKeyParams) ([]QueryMostRecentResultsByKeyRow, error)
	NumResultsOverTime(ctx context.Context, arg NumResultsOverTimeParams) ([]NumResultsOverTimeRow, error)
	NumSubmissionsOverTime(ctx context.Context, arg NumSubmissionsOverTimeParams) ([]NumSubmissionsOverTimeRow, error)
}

type CreateAndReturnNodeParams struct {
	QueueItemID uuid.UUID
	Name        string
}

type CreateEdgeParams struct {
	ParentID int32
	ChildID  int32
}

type CreateIOSpecParams struct {
	NodeID   int32
	Type     IoSpecType
	NodeName string
	InputID  string
	Root     bool
	Value    sql.NullString
	Path     sql.NullString
	Context  sql.NullString
}

type CreateQueueItemParams struct {
	ID        uuid.UUID
	Inputs    []string
	CreatedAt time.Time
}

type CreateResultMetadataParams struct {
	QueueItemID uuid.UUID
	Type        string
	Value       string
}

type CreateResultParams struct {
	NodeID      int32
	ExecutionID sql.NullString
	Stdout      sql.NullString
	Stderr      sql.NullString
	Skipped     sql.NullBool
}

type CreateStatusParams struct {
	NodeID    int32
	Submitted time.Time
	Started   sql.NullTime
	Ended     sql.NullTime
	Status    string
}

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 Edge struct {
	ID       int32
	ParentID int32
	ChildID  int32
}

type GetNodeByIDRow struct {
	ID          sql.NullInt32
	QueueItemID uuid.NullUUID
	Name        sql.NullString
	Submitted   time.Time
	Started     sql.NullTime
	Ended       sql.NullTime
	Status      string
	ExecutionID sql.NullString
	Stdout      sql.NullString
	Stderr      sql.NullString
	Skipped     sql.NullBool
	Inputs      []int32
	Outputs     []int32
	Parents     []int32
	Children    []int32
}

type IoSpec struct {
	ID       int32
	NodeID   int32
	Type     IoSpecType
	NodeName string
	InputID  string
	Root     bool
	Value    sql.NullString
	Path     sql.NullString
	Context  sql.NullString
}

type IoSpecType string

type ListQueueItemsParams struct {
	Reverse    bool
	Sort       string
	PageNumber int32
	PageSize   int32
}

type Node struct {
	ID          int32
	QueueItemID uuid.UUID
	Name        string
}

type NodePersistence interface {
	CreateAndReturnNode(ctx context.Context, arg CreateAndReturnNodeParams) (Node, error)
	GetNodeByID(ctx context.Context, id int32) (GetNodeByIDRow, error)
	CreateEdge(ctx context.Context, arg CreateEdgeParams) error
	CreateIOSpec(ctx context.Context, arg CreateIOSpecParams) error
	GetIOSpecByID(ctx context.Context, id int32) (IoSpec, error)
	CreateStatus(ctx context.Context, arg CreateStatusParams) error
	CreateResult(ctx context.Context, arg CreateResultParams) error
}

type NullIoSpecType struct {
	IoSpecType IoSpecType
	Valid      bool // Valid is true if IoSpecType is not NULL
}

type NumResultsOverTimeParams struct {
	PageNumber int32
	PageSize   int32
}

type NumResultsOverTimeRow struct {
	TbTimestamp time.Time
	Count       int64
	FullCount   int64
}

type NumSubmissionsOverTimeParams struct {
	PageNumber int32
	PageSize   int32
}

type NumSubmissionsOverTimeRow struct {
	TbTimestamp time.Time
	Count       int64
	FullCount   int64
}

type Persistence interface {
	NodePersistence
	Queue
	Analytics
}

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

type QueryMostRecentResultsByKeyParams struct {
	Key        string
	Reverse    bool
	Sort       string
	PageNumber int32
	PageSize   int32
}

type QueryMostRecentResultsByKeyRow struct {
	CreatedAt time.Time
	Value     string
	FullCount int64
}

type QueryTopResultsByKeyParams struct {
	Key        string
	Reverse    bool
	Sort       string
	PageNumber int32
	PageSize   int32
}

type QueryTopResultsByKeyRow struct {
	Value string
	Count int64
}

type Queue interface {
	CreateQueueItem(ctx context.Context, arg CreateQueueItemParams) error
	GetQueueItemDetail(ctx context.Context, id uuid.UUID) (QueueItem, error)
	ListQueueItems(ctx context.Context, arg ListQueueItemsParams) ([]QueueItem, error)
	CountQueueItems(ctx context.Context) (int64, error)
	GetNodesByQueueItemID(ctx context.Context, queueItemID uuid.UUID) ([]Node, error)
	CreateResultMetadata(ctx context.Context, arg CreateResultMetadataParams) error
}

type QueueItem struct {
	ID        uuid.UUID
	Inputs    []string
	CreatedAt time.Time
}

type Result struct {
	ID          int32
	Ts          sql.NullTime
	NodeID      int32
	ExecutionID sql.NullString
	Stdout      sql.NullString
	Stderr      sql.NullString
	Skipped     sql.NullBool
}

type ResultMeta struct {
	Type  string
	Value string
}

type ResultMetadataType struct {
	ID    int32
	Value string
}

type ResultMetadatum struct {
	ID          int32
	QueueItemID uuid.UUID
	TypeID      int32
	Value       string
}

type Status struct {
	ID        int32
	Ts        sql.NullTime
	NodeID    int32
	Submitted time.Time
	Status    string
	Started   sql.NullTime
	Ended     sql.NullTime
}