source

type AdminSourceConfig struct {
	// BaseURL 是 flowlink-admin 的 HTTP 基础地址，例如 http://127.0.0.1:18080。
	// WorkerHTTPClient 会在它后面拼接 worker pull 路径。
	BaseURL string `json:"baseUrl" yaml:"baseUrl"`
	// Token 非空时会作为 worker 认证请求头发送。
	Token string `json:"token" yaml:"token"`
	// HTTPClient 允许调用方注入超时、链路追踪、代理规则或测试客户端。
	// 为空时使用 http.DefaultClient。
	HTTPClient *http.Client `json:"-" yaml:"-"`
}

type MemorySourceConfig struct {
	Workflows []*core.Workflow `json:"workflows" yaml:"workflows"`
}

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

type PollingSourceConfig struct {
	// Interval 是 bootstrap 轮询周期，例如 30s、1m。
	// 为空时使用 PollingWorkflowLoader 的默认周期。
	Interval string `json:"interval" yaml:"interval"`
}

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

type PollingWorkflowLoaderOptions struct {
	// Client 负责访问 flowlink-admin 的 worker pull 接口。
	Client *WorkerHTTPClient
	// Scope 限定要同步的已发布 workflow head 范围。
	Scope ServiceScope
	// PollInterval 控制后台 bootstrap 频率；非正值使用包内默认值。
	PollInterval time.Duration
}

type PollingWorkflowLoaderStatus struct {
	Scope               ServiceScope  `json:"scope"`
	PollInterval        time.Duration `json:"pollInterval"`
	WorkflowCount       int           `json:"workflowCount"`
	CachedWorkflowCount int           `json:"cachedWorkflowCount"`
	LastSyncAt          time.Time     `json:"lastSyncAt"`
	LastSuccessAt       time.Time     `json:"lastSuccessAt"`
	LastError           string        `json:"lastError,omitempty"`
}

type PublishedWorkflowHead = workerpull.PublishedWorkflowHead

type PublishedWorkflowRef struct {
	WorkflowID string `json:"workflowId" yaml:"workflowId"`
	Version    string `json:"version" yaml:"version"`
}

type PublishedWorkflowResolver interface {
	ResolvePublished(ctx context.Context, msg adapter.Message) (*PublishedWorkflowRef, error)
}

type ResolverFunc func(ctx context.Context, msg adapter.Message) (*PublishedWorkflowRef, error)

type ServiceScope = workerpull.ServiceScope

type SourceConfig struct {
	Type    string                 `json:"type" yaml:"type"`
	Admin   AdminSourceConfig      `json:"admin" yaml:"admin"`
	Polling PollingSourceConfig    `json:"polling" yaml:"polling"`
	Memory  MemorySourceConfig     `json:"memory" yaml:"memory"`
	Options map[string]interface{} `json:"options,omitempty" yaml:"options,omitempty"`
}

type WorkerBootstrap = workerpull.WorkerBootstrap

type WorkerHTTPClient struct {
	BaseURL    string
	Token      string
	HTTPClient *http.Client
}

type WorkflowSource interface {
	LoadPublished(ctx context.Context, scope ServiceScope, workflowID string, version string) (*core.Workflow, error)
}

type WorkflowSourceFactory func(ctx context.Context, scope ServiceScope, config SourceConfig) (WorkflowSource, error)