appruntime

type BatchResult struct {
	Results  []EffectResult
	Executed int
	Failed   int
}

type CancelJob struct {
	ScheduleID string
}

type CreateDomainRecord struct {
	RecordType string
	RecordID   string
	DataJSON   string
	Version    string
}

type Dialer func(spec InstanceSpec) (sdkapplication.ApplicationClient, error)

type Effect struct {
	ID             string
	IdempotencyKey string
	TenantID       string
	// PluginInstanceID 标记效果来源实例（Executor 落领域记录/审计用；
	// 不参与授权——授权只看 TenantID 与绑定）。
	PluginInstanceID string
	Kind             EffectKind

	CreateDomainRecord *CreateDomainRecord `json:",omitempty"`
	RequestCommand     *RequestCommand     `json:",omitempty"`
	ScheduleJob        *ScheduleJob        `json:",omitempty"`
	CancelJob          *CancelJob          `json:",omitempty"`
	SendNotification   *SendNotification   `json:",omitempty"`
}

type EffectExecutor interface {
	Execute(ctx context.Context, effect Effect) error
}

type EffectKind string

type EffectResult struct {
	Effect    Effect
	Executed  bool
	Duplicate bool
	Err       error
}

type EffectSource struct {
	PluginInstanceID string
	TenantID         string
	Bindings         []coreapplication.Binding
	Candidates       []coreapplication.Candidate
}

type Instance struct {
	ApplicationID    string
	PluginInstanceID string
	PluginID         string
	TenantID         string
	State            InstanceState
	Err              error

	Descriptor   *sdkapplication.ApplicationDescriptor
	Requirements []coreapplication.Requirement
	Bindings     []coreapplication.Binding
}

type InstanceSpec struct {
	ApplicationID    string
	PluginInstanceID string
	PluginID         string
	TenantID         string

	// PluginVersion is reported to the plugin during Initialize. When empty,
	// the runtime omits it rather than inventing a version.
	PluginVersion string
	// LaunchID is the host-generated launch identity used for the handshake.
	LaunchID string
	// NodeID identifies the node running the instance.
	NodeID string
	// HostInfo carries host metadata for the Initialize handshake.
	HostInfo map[string]string

	// Config and ConfigRevision are passed through to ConfigureInstance.
	Config         []byte
	ConfigRevision uint32

	// Candidates is the bindable view of entities for binding validation.
	Candidates []coreapplication.Candidate
	// Bindings is the proposed binding set for this instance.
	Bindings []coreapplication.Binding

	// EventQueueSize is the per-instance outbound event queue capacity. Zero
	// selects the runtime default.
	EventQueueSize int
}

type InstanceState string

type RequestCommand struct {
	EntityID       string
	Action         string
	ArgsJSON       string
	IdempotencyKey string
	Deadline       string
}

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

type RuntimeOptions struct {
	// Dialer resolves the exact tenant/instance process for the requested
	// definition, including plugin identity and version.
	Dialer Dialer
	// Executor is the Core-provided EffectExecutor.
	Executor EffectExecutor
	// Logger receives structured diagnostics. A discard logger is used when nil.
	Logger *slog.Logger

	// EventQueueSize is the default per-instance event queue capacity.
	EventQueueSize int
	// ShutdownTimeout bounds one graceful instance shutdown.
	ShutdownTimeout time.Duration
	// Context is the parent context for all instance event loops.
	Context context.Context
}

type ScheduleJob struct {
	ScheduleID  string
	Cron        string
	PayloadJSON string
}

type SendNotification struct {
	Title    string
	Body     string
	Severity string
}