messaging

type BucketOptions struct {
	History  uint8 // number of historical values kept per key (rollback depth)
	Replicas int   // 1 for dev, 3 for prod cluster
}

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

type Client struct {
	Conn *nats.Conn
	JS   jetstream.JetStream
}

type Config struct {
	URL           string // e.g. nats://nats:4222 or comma-separated cluster URLs
	CredsFile     string // optional path to a NATS .creds file (NKEY/JWT)
	Name          string // connection name, shown in NATS monitoring
	MaxReconnect  int    // -1 = unlimited
	ReconnectWait time.Duration
}

type ConfigPublisher interface {
	PublishFlag(ctx context.Context, environmentID int64, flagKey string, payload FlagPayload) error
	PublishMicroConfig(ctx context.Context, environmentID, microserviceID int64, settings json.RawMessage) error
	PublishLocalization(ctx context.Context, environmentID, microserviceID int64, locale string, bundle json.RawMessage) error

	// ListKeys returns every key currently held in the named bucket. A bucket
	// that is empty or does not exist yields no keys and no error.
	ListKeys(ctx context.Context, bucket string) ([]string, error)
	// ListRevisions returns the same keys with the revision each one is
	// currently at. The reconciler needs the revisions to tell a key that has
	// sat untouched since its sweep began from one written during it.
	ListRevisions(ctx context.Context, bucket string) ([]KeyRevision, error)
	// DeleteKey removes a key from the named bucket. This is how a row deleted
	// from the database stops being served: without it the KV entry survives
	// forever and consumers keep the stale value in memory.
	DeleteKey(ctx context.Context, bucket, key string) error
	// EnsureBuckets re-provisions the buckets, so a NATS restart with an empty
	// store does not leave every publish failing until this process restarts.
	EnsureBuckets(ctx context.Context) error
}

type FlagPayload struct {
	Enabled   bool   `json:"enabled"`
	Value     string `json:"value"`
	UpdatedAt string `json:"updatedAt"` // RFC3339
}

type KeyRevision struct {
	Key      string
	Revision uint64
}

type NoopPublisher struct{}

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

type ReconcileSource interface {
	// Name identifies the source in logs.
	Name() string
	// Bucket is the KV bucket this source owns. On a complete full sweep the
	// keys Resync returned are taken as the contents of that bucket and
	// everything else in it is a candidate for deletion.
	Bucket() string
	// Resync publishes rows changed at or after `since` and reports the KV keys
	// it published. A zero `since` means "publish everything" (full sweep). An
	// error means the source could not be read at all; a row that could not be
	// published is recorded on the result instead, so one bad row does not
	// strand the ones behind it.
	Resync(ctx context.Context, pub ConfigPublisher, since time.Time) (ResyncResult, error)
}

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

type ResyncResult struct {
	// Keys are the KV keys the sweep published successfully.
	Keys []string
	// Partial is set when at least one row could not be published. The rest of
	// the sweep still ran, but the result no longer describes the bucket, so it
	// may neither be pruned against nor advance the incremental window.
	Partial bool
}