db

package

Go to main page

Versions in this module

v1

v1.0.1

May 9, 2023

v1.0.0

May 9, 2023

v0

v0.5.19

May 8, 2023

v0.5.18

May 5, 2023

v0.5.17

May 5, 2023

v0.5.16

May 5, 2023

v0.5.15

May 5, 2023

v0.5.14

May 4, 2023

v0.5.13

May 3, 2023

Changes in this version

type Analytics

+ CountQueryTopResultsByKey func(ctx context.Context, key string) (int64, error)

+ NumResultsOverTime func(ctx context.Context, arg NumResultsOverTimeParams) ([]NumResultsOverTimeRow, error)

+ NumSubmissionsOverTime func(ctx context.Context, arg NumSubmissionsOverTimeParams) ([]NumSubmissionsOverTimeRow, error)

+ QueryMostRecentResultsByKey func(ctx context.Context, arg QueryMostRecentResultsByKeyParams) ([]QueryMostRecentResultsByKeyRow, error)

+ type NumResultsOverTimeParams struct

+ PageNumber int32

+ PageSize int32

+ type NumResultsOverTimeRow struct

+ Count int64

+ FullCount int64

+ TbTimestamp time.Time

+ type NumSubmissionsOverTimeParams struct

+ PageNumber int32

+ PageSize int32

+ type NumSubmissionsOverTimeRow struct

+ Count int64

+ FullCount int64

+ TbTimestamp time.Time

type Queries

+ func (q *Queries) CountQueryTopResultsByKey(ctx context.Context, key string) (int64, error)

+ func (q *Queries) NumResultsOverTime(ctx context.Context, arg NumResultsOverTimeParams) ([]NumResultsOverTimeRow, error)

+ func (q *Queries) NumSubmissionsOverTime(ctx context.Context, arg NumSubmissionsOverTimeParams) ([]NumSubmissionsOverTimeRow, error)

+ func (q *Queries) QueryMostRecentResultsByKey(ctx context.Context, arg QueryMostRecentResultsByKeyParams) ([]QueryMostRecentResultsByKeyRow, error)

+ type QueryMostRecentResultsByKeyParams struct

+ Key string

+ PageNumber int32

+ PageSize int32

+ Reverse bool

+ Sort string

+ type QueryMostRecentResultsByKeyRow struct

+ CreatedAt time.Time

+ FullCount int64

+ Value string

type QueryTopResultsByKeyParams

+ PageNumber int32

+ Reverse bool

+ Sort string

v0.5.12

May 3, 2023

v0.5.11

May 2, 2023

v0.5.10

May 2, 2023

v0.5.9

Apr 28, 2023

v0.5.8

Apr 28, 2023

v0.5.7

Apr 28, 2023

v0.5.6

Apr 27, 2023

v0.5.5

Apr 26, 2023

v0.5.4

Apr 26, 2023

v0.5.3

Apr 26, 2023

Changes in this version

type Analytics

+ CreateResultMetadata func(ctx context.Context, arg CreateResultMetadataParams) error

v0.5.2

Apr 26, 2023

Changes in this version

+ type Analytics interface

+ QueryTopResultsByKey func(ctx context.Context, arg QueryTopResultsByKeyParams) ([]QueryTopResultsByKeyRow, error)

+ type CreateResultMetadataParams struct

+ QueueItemID uuid.UUID

+ Type string

+ Value string

type Queries

+ func (q *Queries) CreateResultMetadata(ctx context.Context, arg CreateResultMetadataParams) error

+ func (q *Queries) QueryTopResultsByKey(ctx context.Context, arg QueryTopResultsByKeyParams) ([]QueryTopResultsByKeyRow, error)

+ type QueryTopResultsByKeyParams struct

+ Key string

+ PageSize int32

+ type QueryTopResultsByKeyRow struct

+ Count int64

+ Value string

type Queue

+ CreateResultMetadata func(ctx context.Context, arg CreateResultMetadataParams) error

+ 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

v0.5.1

Apr 24, 2023

Changes in this version

type ListQueueItemsParams

+ Sort string

v0.5.0

Apr 24, 2023

Changes in this version

type ListQueueItemsParams

+ PageNumber int32

+ PageSize int32

type Queries

+ func (q *Queries) CountQueueItems(ctx context.Context) (int64, error)

type Queue

+ CountQueueItems func(ctx context.Context) (int64, error)

v0.4.4

Apr 22, 2023

v0.4.3

Apr 22, 2023

v0.4.2

Apr 21, 2023

v0.4.1

Apr 21, 2023

v0.4.0

Apr 20, 2023

v0.3.9

Apr 19, 2023

v0.3.8

Apr 18, 2023

v0.3.7

Apr 18, 2023

v0.3.6

Apr 17, 2023

Changes in this version

+ type ListQueueItemsParams struct

+ Createdafter time.Time

+ Createdbefore time.Time

+ Limit int32

+ Reverse bool

v0.3.5

Apr 17, 2023

v0.3.4

Apr 17, 2023

v0.3.3

Apr 17, 2023

v0.3.2

Apr 16, 2023

Changes in this version

+ type CreateAndReturnNodeParams struct

+ Name string

+ QueueItemID uuid.UUID

type NodePersistence

+ CreateAndReturnNode func(ctx context.Context, arg CreateAndReturnNodeParams) (Node, error)

type Queries

+ func (q *Queries) CreateAndReturnNode(ctx context.Context, arg CreateAndReturnNodeParams) (Node, error)

v0.3.1

Apr 15, 2023

v0.3.0

Apr 15, 2023

Changes in this version

+ var ErrNotFound = fmt.Errorf("not found")

+ type CreateEdgeParams struct

+ ChildID int32

+ ParentID int32

+ type CreateIOSpecParams struct

+ Context sql.NullString

+ InputID string

+ NodeID int32

+ NodeName string

+ Path sql.NullString

+ Root bool

+ Type IoSpecType

+ Value sql.NullString

+ type CreateNodeReturnIdParams struct

+ Name string

+ QueueItemID uuid.UUID

+ type CreateQueueItemParams struct

+ CreatedAt time.Time

+ ID uuid.UUID

+ Inputs []string

+ type CreateResultParams struct

+ ExecutionID sql.NullString

+ NodeID int32

+ Skipped sql.NullBool

+ Stderr sql.NullString

+ Stdout sql.NullString

+ type CreateStatusParams struct

+ Ended sql.NullTime

+ NodeID int32

+ Started sql.NullTime

+ Status string

+ Submitted time.Time

+ type DBTX interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type Edge struct

+ ChildID int32

+ ID int32

+ ParentID int32

+ type GetNodeByIDRow struct

+ Children []int32

+ Ended sql.NullTime

+ ExecutionID sql.NullString

+ ID sql.NullInt32

+ Inputs []int32

+ Name sql.NullString

+ Outputs []int32

+ Parents []int32

+ QueueItemID uuid.NullUUID

+ Skipped sql.NullBool

+ Started sql.NullTime

+ Status string

+ Stderr sql.NullString

+ Stdout sql.NullString

+ Submitted time.Time

+ type IoSpec struct

+ Context sql.NullString

+ ID int32

+ InputID string

+ NodeID int32

+ NodeName string

+ Path sql.NullString

+ Root bool

+ Type IoSpecType

+ Value sql.NullString

+ type IoSpecType string

+ const IoSpecTypeInput

+ const IoSpecTypeOutput

+ func (e *IoSpecType) Scan(src interface{}) error

+ type Node struct

+ ID int32

+ Name string

+ QueueItemID uuid.UUID

+ type NodePersistence interface

+ CreateEdge func(ctx context.Context, arg CreateEdgeParams) error

+ CreateIOSpec func(ctx context.Context, arg CreateIOSpecParams) error

+ CreateNodeReturnId func(ctx context.Context, arg CreateNodeReturnIdParams) (int32, error)

+ CreateResult func(ctx context.Context, arg CreateResultParams) error

+ CreateStatus func(ctx context.Context, arg CreateStatusParams) error

+ GetIOSpecByID func(ctx context.Context, id int32) (IoSpec, error)

+ GetNodeByID func(ctx context.Context, id int32) (GetNodeByIDRow, error)

+ type NullIoSpecType struct

+ IoSpecType IoSpecType

+ Valid bool

+ func (ns *NullIoSpecType) Scan(value interface{}) error

+ func (ns NullIoSpecType) Value() (driver.Value, error)

+ type Persistence interface

+ func NewInMemDB() Persistence

+ func NewPostgresDB(connStr string) (Persistence, error)

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CreateEdge(ctx context.Context, arg CreateEdgeParams) error

+ func (q *Queries) CreateIOSpec(ctx context.Context, arg CreateIOSpecParams) error

+ func (q *Queries) CreateNodeReturnId(ctx context.Context, arg CreateNodeReturnIdParams) (int32, error)

+ func (q *Queries) CreateQueueItem(ctx context.Context, arg CreateQueueItemParams) error

+ func (q *Queries) CreateResult(ctx context.Context, arg CreateResultParams) error

+ func (q *Queries) CreateStatus(ctx context.Context, arg CreateStatusParams) error

+ func (q *Queries) GetIOSpecByID(ctx context.Context, id int32) (IoSpec, error)

+ func (q *Queries) GetNodeByID(ctx context.Context, nodeID int32) (GetNodeByIDRow, error)

+ func (q *Queries) GetNodesByQueueItemID(ctx context.Context, queueItemID uuid.UUID) ([]Node, error)

+ func (q *Queries) GetQueueItemDetail(ctx context.Context, id uuid.UUID) (QueueItem, error)

+ func (q *Queries) ListQueueItems(ctx context.Context) ([]QueueItem, error)

+ func (q *Queries) WithTx(tx *sql.Tx) *Queries

+ type Queue interface

+ CreateQueueItem func(ctx context.Context, arg CreateQueueItemParams) error

+ GetNodesByQueueItemID func(ctx context.Context, queueItemID uuid.UUID) ([]Node, error)

+ GetQueueItemDetail func(ctx context.Context, id uuid.UUID) (QueueItem, error)

+ ListQueueItems func(ctx context.Context) ([]QueueItem, error)

+ type QueueItem struct

+ CreatedAt time.Time

+ ID uuid.UUID

+ Inputs []string

+ type Result struct

+ ExecutionID sql.NullString

+ ID int32

+ NodeID int32

+ Skipped sql.NullBool

+ Stderr sql.NullString

+ Stdout sql.NullString

+ Ts sql.NullTime

+ type Status struct

+ Ended sql.NullTime

+ ID int32

+ NodeID int32

+ Started sql.NullTime

+ Status string

+ Submitted time.Time

+ Ts sql.NullTime

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL