store

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 7, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrDuplicate = errors.New("project workflow chain resource already exists")
View Source 
var ErrNotFound = errors.New("project workflow chain resource not found")

Functions

This section is empty.

Types

type LadybugStore 

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

func NewBootstrappedLadybugStore 

func NewBootstrappedLadybugStore(ctx context.Context, graph ladybug.Graph) (*LadybugStore, error)

func NewLadybugStore 

func NewLadybugStore(graph ladybug.Graph) *LadybugStore

func (*LadybugStore) CreateChainRun 

func (store *LadybugStore) CreateChainRun(ctx context.Context, run projectworkflowchain.ChainRun) (projectworkflowchain.ChainRun, error)

func (*LadybugStore) FindChainRunByWorkPlan 

func (store *LadybugStore) FindChainRunByWorkPlan(ctx context.Context, projectID, workPlanID string) (projectworkflowchain.ChainRun, error)

func (*LadybugStore) GetChainRun 

func (store *LadybugStore) GetChainRun(ctx context.Context, projectID, chainRunID string) (projectworkflowchain.ChainRun, error)

func (*LadybugStore) ListChainRuns 

func (store *LadybugStore) ListChainRuns(ctx context.Context, filter projectworkflowchain.ChainFilter) ([]projectworkflowchain.ChainRun, error)

func (*LadybugStore) UpdateChainRun 

func (store *LadybugStore) UpdateChainRun(ctx context.Context, run projectworkflowchain.ChainRun) (projectworkflowchain.ChainRun, error)

type MemoryStore 

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

func NewMemoryStore 

func NewMemoryStore() *MemoryStore

func (*MemoryStore) CreateChainRun 

func (store *MemoryStore) CreateChainRun(_ context.Context, run projectworkflowchain.ChainRun) (projectworkflowchain.ChainRun, error)

func (*MemoryStore) FindChainRunByWorkPlan 

func (store *MemoryStore) FindChainRunByWorkPlan(_ context.Context, projectID, workPlanID string) (projectworkflowchain.ChainRun, error)

func (*MemoryStore) GetChainRun 

func (store *MemoryStore) GetChainRun(_ context.Context, projectID, chainRunID string) (projectworkflowchain.ChainRun, error)

func (*MemoryStore) ListChainRuns 

func (store *MemoryStore) ListChainRuns(_ context.Context, filter projectworkflowchain.ChainFilter) ([]projectworkflowchain.ChainRun, error)

func (*MemoryStore) UpdateChainRun 

func (store *MemoryStore) UpdateChainRun(_ context.Context, run projectworkflowchain.ChainRun) (projectworkflowchain.ChainRun, error)

type Store 

type Store interface {
	CreateChainRun(context.Context, projectworkflowchain.ChainRun) (projectworkflowchain.ChainRun, error)
	GetChainRun(context.Context, string, string) (projectworkflowchain.ChainRun, error)
	ListChainRuns(context.Context, projectworkflowchain.ChainFilter) ([]projectworkflowchain.ChainRun, error)
	UpdateChainRun(context.Context, projectworkflowchain.ChainRun) (projectworkflowchain.ChainRun, error)
	FindChainRunByWorkPlan(context.Context, string, string) (projectworkflowchain.ChainRun, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.