source

type Adapter ¶

type Adapter[I any, S Value, V any] interface {
	Name() string
	Resolve(context.Context, I) (S, error)
	Read(context.Context, S) (V, error)
}

Adapter resolves one exact input type and reads one exact Source type.

type AdapterNotFoundError ¶

type AdapterNotFoundError struct {
	Route string
	Type  reflect.Type
}

AdapterNotFoundError reports that no adapter owns an exact Go type.

func (e *AdapterNotFoundError) Error() string

type Catalog ¶

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

Catalog is an immutable adapter registry over persisted Source reads.

func NewCatalog(backend CatalogBackend, registry Registry) (*Catalog, error)

func (c *Catalog) Get(ctx context.Context, value Value) (Value, error)

func (c *Catalog) List(ctx context.Context) ([]Value, error)

func (c *Catalog) Read(ctx context.Context, value Value) (any, error)

func (c *Catalog) Ref(value Value) (Ref, error)

func (c *Catalog) Resolve(ctx context.Context, input any) (Value, error)

type CatalogBackend ¶

type CatalogBackend interface {
	Get(context.Context, Value) (Value, error)
	List(context.Context) ([]Value, error)
}

CatalogBackend provides persisted Source reads.

type ConflictError ¶

type ConflictError struct {
	Field string
	Value any
}

ConflictError reports ambiguous immutable catalog routing.

func (e *ConflictError) Error() string

type ContentAdapter ¶

type ContentAdapter struct{}

func (ContentAdapter) Name() string

func (ContentAdapter) Read(_ context.Context, value ContentSource) (ContentCapture, error)

func (ContentAdapter) Resolve(_ context.Context, value ContentCapture) (ContentSource, error)

type ContentCapture ¶

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

ContentCapture is text supplied by an integration with a caller-stable identity. Metadata is copied recursively at construction and access.

func NewContentCapture(sourceID, content string, metadata map[string]any) (ContentCapture, error)

func (c ContentCapture) Content() string

func (c ContentCapture) ID() string

func (c ContentCapture) Metadata() map[string]any

type ContentSource ¶

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

ContentSource is captured neutral text usable as Artifact evidence.

func RestoreContentSource(
	name string,
	materialization Materialization,
	description *string,
	content string,
	metadata map[string]any,
) (ContentSource, error)

func (s ContentSource) Content() string

func (s ContentSource) Metadata() map[string]any

func (s ContentSource) SourceDescription() (string, bool)

func (s ContentSource) SourceMaterialization() Materialization

func (s ContentSource) SourceName() string

type Cursor ¶

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

Cursor is the last Source journal sequence consumed by one binding. It is a value type because trigger transitions are pure.

func NewCursor(sequence int64) Cursor

func (c Cursor) Sequence() int64

type InvalidAdapterError ¶

type InvalidAdapterError struct {
	Type   reflect.Type
	Field  string
	Detail string
}

InvalidAdapterError reports an invalid adapter declaration.

func (e *InvalidAdapterError) Error() string

type InvalidEntryError ¶

type InvalidEntryError struct {
	Type reflect.Type
}

InvalidEntryError reports a value that does not satisfy the Source contract.

func (e *InvalidEntryError) Error() string

type InvalidReferenceError ¶

type InvalidReferenceError struct {
	Field  string
	Detail string
}

InvalidReferenceError reports an invalid Source identity.

func (e *InvalidReferenceError) Error() string

type InvalidResultError ¶

type InvalidResultError struct {
	AdapterName string
	Operation   string
	Expected    reflect.Type
	Actual      reflect.Type
}

InvalidResultError reports an adapter that returned a value outside its declared exact Source type.

func (e *InvalidResultError) Error() string

type JournalEntry ¶

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

JournalEntry is one resolved Source in stable per-scope insertion order. The Source value is immutable by contract; concrete built-ins copy mutable fields at their access boundaries.

func NewJournalEntry(ref Ref, value Value, position int64) (JournalEntry, error)

func (e JournalEntry) Position() int64

func (e JournalEntry) Ref() Ref

func (e JournalEntry) Value() Value

type Materialization ¶

type Materialization string

Materialization describes where a value read for a Source comes from.

const (
	Captured   Materialization = "captured"
	Referenced Materialization = "referenced"
)

type NotFoundError ¶

type NotFoundError struct {
	Source Value
}

NotFoundError reports that an exact Source value is absent from a catalog.

func (e *NotFoundError) Error() string

type Ref ¶

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

Ref is a stable reference to one Source in a catalog view.

func NewRef(sourceType, sourceID string) (Ref, error)

func (r Ref) ID() string

func (r Ref) MarshalText() ([]byte, error)

func (r Ref) String() string

func (r Ref) Type() string

type Registry ¶

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

Registry is a mutable builder for immutable Catalog routing.

type Service ¶

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

Service composes Source acquisition, persistence, and read operations.

func NewService(catalog *Catalog, store Store) (*Service, error)

func (s *Service) Add(ctx context.Context, value Value) (Value, error)

func (s *Service) Get(ctx context.Context, value Value) (Value, error)

func (s *Service) List(ctx context.Context) ([]Value, error)

func (s *Service) Read(ctx context.Context, value Value) (any, error)

func (s *Service) Ref(value Value) (Ref, error)

func (s *Service) Resolve(ctx context.Context, input any) (Value, error)

type Store ¶

type Store interface {
	Add(context.Context, Value) (Value, error)
}

Store persists resolved Sources for later catalog reads and lineage.

type Value ¶

type Value interface {
	SourceName() string
	SourceMaterialization() Materialization
	SourceDescription() (string, bool)
}

Value is an immutable adapter-owned Source description. Implementations should use value receivers or otherwise prevent callers from changing the identity returned by SourceName.