db

package

Go to main page

Versions in this module

v0

v0.8.0

Oct 6, 2022

v0.8.0-rc2

Oct 6, 2022

v0.8.0-rc1

Oct 4, 2022

v0.7.0

Aug 29, 2022

Changes in this version

+ type WorkerWorkflow interface

+ GetWorkflowActions func(ctx context.Context, wfID string) (*pb.WorkflowActionList, error)

+ GetWorkflowContexts func(ctx context.Context, wfID string) (*pb.WorkflowContext, error)

+ GetWorkflowsForWorker func(ctx context.Context, id string) ([]string, error)

+ GetfromWfDataTable func(ctx context.Context, req *pb.GetWorkflowDataRequest) ([]byte, error)

+ InsertIntoWfDataTable func(ctx context.Context, req *pb.UpdateWorkflowDataRequest) error

+ UpdateWorkflowState func(ctx context.Context, wfContext *pb.WorkflowContext) error

v0.7.0-rc1

Aug 29, 2022

v0.6.0

Sep 10, 2021

v0.5.0

Mar 15, 2021

v0.4.0

Jan 4, 2021

v0.3.0

Jan 4, 2021

Changes in this version

type TinkDB

+ func (d TinkDB) Events(req *events.WatchRequest, fn func(n informers.Notification) error) error

+ func (t *TinkDB) PurgeEvents(errCh chan<- error)

v0.2.1

Nov 9, 2020

v0.2.0

Nov 9, 2020

Changes in this version

type TinkDB

+ func (t *TinkDB) CheckRequiredMigrations() (int, error)

+ func (t *TinkDB) Migrate() (int, error)

v0.1.0

Aug 20, 2020

Changes in this version

+ func Error(err error) *pq.Error

+ type Database interface

+ type TinkDB struct

+ func Connect(lg log.Logger) *TinkDB

+ func (d TinkDB) CreateTemplate(ctx context.Context, name string, data string, id uuid.UUID) error

+ func (d TinkDB) CreateWorkflow(ctx context.Context, wf Workflow, data string, id uuid.UUID) error

+ func (d TinkDB) DeleteFromDB(ctx context.Context, id string) error

+ func (d TinkDB) DeleteTemplate(ctx context.Context, name string) error

+ func (d TinkDB) DeleteWorkflow(ctx context.Context, id string, state int32) error

+ func (d TinkDB) GetAll(fn func([]byte) error) error

+ func (d TinkDB) GetByID(ctx context.Context, id string) (string, error)

+ func (d TinkDB) GetByIP(ctx context.Context, ip string) (string, error)

+ func (d TinkDB) GetByMAC(ctx context.Context, mac string) (string, error)

+ func (d TinkDB) GetTemplate(ctx context.Context, id string) (string, string, error)

+ func (d TinkDB) GetWorkflow(ctx context.Context, id string) (Workflow, error)

+ func (d TinkDB) GetWorkflowActions(ctx context.Context, wfID string) (*pb.WorkflowActionList, error)

+ func (d TinkDB) GetWorkflowContexts(ctx context.Context, wfID string) (*pb.WorkflowContext, error)

+ func (d TinkDB) GetWorkflowDataVersion(ctx context.Context, workflowID string) (int32, error)

+ func (d TinkDB) GetWorkflowMetadata(ctx context.Context, req *pb.GetWorkflowDataRequest) ([]byte, error)

+ func (d TinkDB) GetWorkflowsForWorker(id string) ([]string, error)

+ func (d TinkDB) GetfromWfDataTable(ctx context.Context, req *pb.GetWorkflowDataRequest) ([]byte, error)

+ func (d TinkDB) InsertIntoDB(ctx context.Context, data string) error

+ func (d TinkDB) InsertIntoWfDataTable(ctx context.Context, req *pb.UpdateWorkflowDataRequest) error

+ func (d TinkDB) InsertIntoWorkflowEventTable(ctx context.Context, wfEvent *pb.WorkflowActionStatus, time time.Time) error

+ func (d TinkDB) ListTemplates(fn func(id, n string, in, del *timestamp.Timestamp) error) error

+ func (d TinkDB) ListWorkflows(fn func(wf Workflow) error) error

+ func (d TinkDB) ShowWorkflowEvents(wfID string, fn func(wfs *pb.WorkflowActionStatus) error) error

+ func (d TinkDB) UpdateTemplate(ctx context.Context, name string, data string, id uuid.UUID) error

+ func (d TinkDB) UpdateWorkflow(ctx context.Context, wf Workflow, state int32) error

+ func (d TinkDB) UpdateWorkflowState(ctx context.Context, wfContext *pb.WorkflowContext) error

+ type Workflow struct

+ CreatedAt *timestamp.Timestamp

+ Hardware string

+ ID string

+ State int32

+ Template string

+ UpdatedAt *timestamp.Timestamp

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