runtime

type Admission struct {
	ExecutionID              string         `json:"execution_id"`
	AdmissionID              string         `json:"admission_id,omitempty"`
	TenantNamespace          string         `json:"tenant_namespace"`
	Ruleset                  string         `json:"ruleset"`
	Version                  string         `json:"version"`
	Facts                    map[string]any `json:"facts"`
	MergePolicy              string         `json:"merge_policy,omitempty"`
	ExpectedGenerationDigest string         `json:"expected_generation_digest,omitempty"`
}

type ArtifactResolver interface {
	ResolveGeneration(context.Context, ledger.ExecutionArtifact) (*Generation, error)
}

type ArtifactResolverFunc func(context.Context, ledger.ExecutionArtifact) (*Generation, error)

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

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

type EngineExecutionService struct {
	effectusv1.UnimplementedRulesetExecutionServiceServer
	Engine *Engine
	// contains filtered or unexported fields
}

type EngineExecutionServiceOptions struct {
	RulesetName string
	Version     string
}

type ExecuteRequest struct {
	Admission         *Admission
	ResumeExecutionID string
	WaitMode          WaitMode
	RecoveryLease     *schema.ExecutionLease
}

type ExecuteResult struct {
	ExecutionID      string `json:"execution_id"`
	GenerationDigest string `json:"generation_digest"`
	State            string `json:"state"`
	DurablyAccepted  bool   `json:"durably_accepted"`
	Completed        bool   `json:"completed"`
}

type GRPCAuthenticator interface {
	Authenticate(context.Context, string) (context.Context, error)
}

type GRPCAuthenticatorFunc func(context.Context, string) (context.Context, error)

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

type GenerationBuildConfig struct {
	Bundle         *bundle.SourceBundle
	CompileOptions compiler.CompileOptions
	Resolvers      *invocation.Registry
	FunctionIDs    map[string]string
	Production     bool
}

type GenerationConfig struct {
	Checked             *ir.Checked
	Environment         ir.Environment
	Ruleset             string
	Version             string
	ExecutorDescriptors map[string]invocation.Descriptor
	FunctionIDs         map[string]string
	SourceDigest        string
	Executors           map[string]invocation.Executor
	Closers             []io.Closer
	Production          bool
}

type GenerationView struct {
	Ruleset          string
	Version          string
	GenerationDigest string
	IRDigest         string
	SourceDigest     string
	Environment      ir.Environment
	Plans            []PlanView
}

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

type Observer interface {
	ObserveExecution(ExecuteResult, error)
	ObserveRecovery(RecoveryObservation)
}

type PlanEvaluation struct {
	Plan    PlanView
	Matched bool
}

type PlanView struct {
	ID        string
	Dialect   effectusv1.SourceDialect
	Priority  int32
	Predicate string
	Verbs     []string
}

type RecoveryObservation struct {
	BacklogMeasured                     bool
	Backlog, Blocked                    int64
	OldestExecutionAge, OldestOutboxAge time.Duration
	ExecutionID, State                  string
	Err                                 error
}

type RecoveryWorker struct {
	Engine        *Engine
	Store         ledger.ExecutionLedger
	Owner         string
	BatchSize     int
	LeaseDuration time.Duration
	PollInterval  time.Duration
	Observer      Observer
}

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

type RulesetExecutionServerOptions struct {
	MaxReceiveBytes        int
	MaxSendBytes           int
	MaxExecutionDuration   time.Duration
	MaxConcurrentRPCs      int
	Authenticator          GRPCAuthenticator
	AllowUnauthenticated   bool
	TLSConfig              *tls.Config
	AllowInsecureTransport bool
	RulesetName            string
	Version                string
}

type WaitMode string