taskchainservice

Documentation

Index

• type Service
  • func New(db libdb.DBManager) Service
  • func WithActivityTracker(service Service, tracker libtracker.ActivityTracker) Service

Types

type Service

type Service interface {
	// Create a new task chain
	Create(ctx context.Context, chain *taskengine.TaskChainDefinition) error

	// Get a task chain by ID
	Get(ctx context.Context, id string) (*taskengine.TaskChainDefinition, error)

	// Update an existing task chain
	Update(ctx context.Context, chain *taskengine.TaskChainDefinition) error

	// Delete a task chain
	Delete(ctx context.Context, id string) error

	// List task chains with pagination
	List(ctx context.Context, cursor *time.Time, limit int) ([]*taskengine.TaskChainDefinition, error)
}

func New

func New(db libdb.DBManager) Service

func WithActivityTracker

func WithActivityTracker(service Service, tracker libtracker.ActivityTracker) Service

WithActivityTracker wraps a task chain service with activity tracking capabilities