clients

type Backtest struct {
	ID uuid.UUID
	// contains filtered or unexported fields
}

type Client interface {
	// NewBacktest creates a new backtest.
	NewBacktest(
		ctx context.Context,
		params backtest.Parameters,
		callbacks runtime.Callbacks,
	) (Backtest, error)
	// GetBacktest gets a backtest.
	GetBacktest(
		ctx context.Context,
		params api.GetBacktestWorkflowParams,
	) (Backtest, error)
	// ListBacktests lists backtests.
	ListBacktests(
		ctx context.Context,
		params api.ListBacktestsWorkflowParams,
	) ([]Backtest, error)
	// Info calls the service info.
	Info(ctx context.Context) (api.ServiceInfoResults, error)
}

type CreateParams struct {
	BacktestParameters backtest.Parameters
	Runner             runtime.Runnable
	Worker             worker.Worker
	TaskQueue          string
}

type RawClient interface {
	CreateBacktest(
		ctx context.Context,
		params api.CreateBacktestWorkflowParams,
	) (api.CreateBacktestWorkflowResults, error)
	RunBacktest(
		ctx context.Context,
		params api.RunBacktestWorkflowParams,
	) (api.RunBacktestWorkflowResults, error)
	GetBacktest(
		ctx context.Context,
		params api.GetBacktestWorkflowParams,
	) (api.GetBacktestWorkflowResults, error)
	ListBacktests(
		ctx context.Context,
		params api.ListBacktestsWorkflowParams,
	) (api.ListBacktestsWorkflowResults, error)
	SubscribeToPrice(
		ctx context.Context,
		params api.SubscribeToPriceWorkflowParams,
	) (api.SubscribeToPriceWorkflowResults, error)
}

type WfClient interface {
	// SubscribeToPrice subscribes to specific price updates.
	SubscribeToPrice(
		ctx workflow.Context,
		params api.SubscribeToPriceWorkflowParams,
	) (api.SubscribeToPriceWorkflowResults, error)
}