projection

type AppendEvidenceMutation struct {
	Contract string
	EntityID string
	Evidence []message.Triple
	Metadata MutationMetadata
}

type AuthoritativeReader interface {
	ReadAuthoritative(context.Context, string) (*graph.EntityState, error)
}

type CommitState string

type Contract struct {
	// Name identifies the projection — typically the payload MessageType it is
	// co-located with, or a logical projection name. Used as the registry key
	// and in error messages.
	Name string `json:"name"`
	// MessageType is the payload type whose Graphable this contract projects for.
	// Stamped onto every derived ForeignEdgeClaim as its Producer so the T2-seam
	// reject can key on (message_type, predicate) (ADR-056 Decision 4). Optional:
	// empty derives Producer-empty ("any producer") foreign edges — the
	// transitional shape. A contract WITH foreign edges should name its type.
	MessageType string `json:"message_type,omitempty"`
	// EntityPattern is the 6-part entity-ID glob the projection writes (the
	// entity it owns).
	EntityPattern string `json:"entity_pattern"`
	// Groups are the owned/append predicate groups by write mode.
	Groups []PredicateGroup `json:"groups,omitempty"`
	// BirthPredicates are a MutationClient convention: they authorize
	// primary-subject facts only on CreateWithTriples and derive no ownership
	// claim. The graph mutation service does not independently make these
	// predicates immutable; writers outside this client contract can still
	// mutate them.
	BirthPredicates []string `json:"birth_predicates,omitempty"`
	// ForeignEdges are the relationship edges the projection writes onto other
	// entities.
	ForeignEdges []ForeignEdge `json:"foreign_edges,omitempty"`
	// IndexingProfile (ADR-054, optional): one of content|control|signal|trace.
	IndexingProfile string `json:"indexing_profile,omitempty"`
}

type CreateMutation struct {
	Contract string
	Entity   *graph.EntityState
	Triples  []message.Triple
	Metadata MutationMetadata
}

type EntityCreator interface {
	CreateWithTriples(context.Context, CreateMutation) (MutationReceipt, error)
}

type EvidenceAppender interface {
	AppendEvidence(context.Context, AppendEvidenceMutation) (MutationReceipt, error)
}

type ForeignEdge struct {
	Predicate     string             `json:"predicate"`
	Mode          ownership.EdgeMode `json:"mode"`
	TargetPattern string             `json:"target_pattern,omitempty"`
}

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

type MutationClientConfig struct {
	NATS        *natsclient.Client
	Registry    *ownership.Registry
	Heartbeater *ownership.Heartbeater
	Owner       string
	Contracts   []Contract
	Timeout     time.Duration
	Retry       natsclient.RetryConfig
}

type MutationError struct {
	Operation MutationOperation
	Kind      MutationErrorKind
	Code      string
	Class     errs.ErrorClass
	Commit    CommitState
	Detail    map[string]any
	Err       error
}

type MutationErrorKind string

type MutationMetadata struct {
	RequestID string
	TraceID   string
	Source    string
	Timestamp time.Time
}

type MutationOperation string

type MutationReceipt struct {
	Entity     *graph.EntityState
	KVRevision uint64
	Commit     CommitState
	Degraded   bool
}

type OwnedReplacer interface {
	ReplaceOwned(context.Context, ReplaceOwnedMutation) (MutationReceipt, error)
}

type PredicateGroup struct {
	Name       string              `json:"name,omitempty"`
	Mode       ownership.WriteMode `json:"mode"`
	Predicates []string            `json:"predicates"`
}

type ReplaceOwnedMutation struct {
	Contract string
	Group    string
	EntityID string
	Desired  []message.Triple
	Metadata MutationMetadata
}