Chronacta Connector

Это содержимое пока не доступно на вашем языке.

Managed durable subscription runner with NATS-style reconnect via pkg/client/resilience.

Binary

make build
./bin/chronacta-connector -config connector.yaml

Configuration

See examples/connector-test/connector.yaml.

Field	Description
`chronacta.address`	gRPC server address
`chronacta.token_env`	env var with bearer token
`jobs[].handler`	`http` or `go:StructuredLog` / `go:NoOp`
`jobs[].type`	`durable` (pull/ack loop)

Handlers

HTTP: POST JSON event; optional HMAC in X-Chronacta-Signature when http.secret_env set.
Go handlers: register at compile time with connector.Register in a custom main fork.
go:PostgresReadModel: projects events into Postgres using a YAML read-model schema (postgres.schema + postgres.dsn_env). Apply DDL from chronacta sqlgen generate ddl before starting. See postgres-projections.md and examples/postgres-projector/.

Idempotency

HTTP receivers must deduplicate by event_id. Delivery is at-least-once. PostgresReadModel uses processed_events + UPSERT and ACKs only after a successful commit.