Documentation ¶
Index ¶
- Variables
- type CreateAndReturnNodeParams
- type CreateEdgeParams
- type CreateIOSpecParams
- type CreateQueueItemParams
- type CreateResultParams
- type CreateStatusParams
- type DBTX
- type Edge
- type GetNodeByIDRow
- type IoSpec
- type IoSpecType
- type ListQueueItemsParams
- type Node
- type NodePersistence
- type NullIoSpecType
- type Persistence
- type Queries
- func (q *Queries) CreateAndReturnNode(ctx context.Context, arg CreateAndReturnNodeParams) (Node, error)
- func (q *Queries) CreateEdge(ctx context.Context, arg CreateEdgeParams) error
- func (q *Queries) CreateIOSpec(ctx context.Context, arg CreateIOSpecParams) 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, arg ListQueueItemsParams) ([]QueueItem, error)
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type Queue
- type QueueItem
- type Result
- type Status
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNotFound = fmt.Errorf("not found")
)
Functions ¶
This section is empty.
Types ¶
type CreateAndReturnNodeParams ¶ added in v0.3.2
type CreateEdgeParams ¶
type CreateIOSpecParams ¶
type CreateIOSpecParams struct { NodeID int32 Type IoSpecType NodeName string InputID string Root bool Value sql.NullString Path sql.NullString Context sql.NullString }
type CreateQueueItemParams ¶
type CreateResultParams ¶
type CreateResultParams struct { NodeID int32 ExecutionID sql.NullString Stdout sql.NullString Stderr sql.NullString Skipped sql.NullBool }
type CreateStatusParams ¶
type GetNodeByIDRow ¶
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 ¶
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 ¶
type IoSpecType string
const ( IoSpecTypeInput IoSpecType = "input" IoSpecTypeOutput IoSpecType = "output" )
func (*IoSpecType) Scan ¶
func (e *IoSpecType) Scan(src interface{}) error
type ListQueueItemsParams ¶ added in v0.3.6
type NodePersistence ¶
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 ¶
type NullIoSpecType struct { IoSpecType IoSpecType Valid bool // Valid is true if IoSpecType is not NULL }
func (*NullIoSpecType) Scan ¶
func (ns *NullIoSpecType) Scan(value interface{}) error
Scan implements the Scanner interface.
type Persistence ¶
type Persistence interface { NodePersistence Queue }
func NewInMemDB ¶
func NewInMemDB() Persistence
func NewPostgresDB ¶
func NewPostgresDB(connStr string) (Persistence, error)
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) CreateAndReturnNode ¶ added in v0.3.2
func (*Queries) CreateEdge ¶
func (q *Queries) CreateEdge(ctx context.Context, arg CreateEdgeParams) error
func (*Queries) CreateIOSpec ¶
func (q *Queries) CreateIOSpec(ctx context.Context, arg CreateIOSpecParams) error
func (*Queries) CreateQueueItem ¶
func (q *Queries) CreateQueueItem(ctx context.Context, arg CreateQueueItemParams) error
func (*Queries) CreateResult ¶
func (q *Queries) CreateResult(ctx context.Context, arg CreateResultParams) error
func (*Queries) CreateStatus ¶
func (q *Queries) CreateStatus(ctx context.Context, arg CreateStatusParams) error
func (*Queries) GetIOSpecByID ¶
func (*Queries) GetNodeByID ¶
func (*Queries) GetNodesByQueueItemID ¶
func (*Queries) GetQueueItemDetail ¶
func (*Queries) ListQueueItems ¶
type Queue ¶
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) GetNodesByQueueItemID(ctx context.Context, queueItemID uuid.UUID) ([]Node, error) }
type Result ¶
type Result struct { ID int32 Ts sql.NullTime NodeID int32 ExecutionID sql.NullString Stdout sql.NullString Stderr sql.NullString Skipped sql.NullBool }
Click to show internal directories.
Click to hide internal directories.