configsnapshot

type Codec ¶

type Codec struct{}

func NewCodec() Codec

func (Codec) Decode(raw []byte) (*readmodel.Snapshot, error)

func (Codec) Encode(snapshot *readmodel.Snapshot) ([]byte, error)

func (Codec) Version(raw []byte) string

type DistributedSignaler ¶ added in v0.5.0

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

DistributedSignaler recompiles the snapshot on the local admin process and fans the same nudge out to every other admin replica over the Redis event bus.

Version broadcast to data planes is in-process per admin pod: a write handled by replica A only reaches the data planes streaming from A. Publishing a SnapshotDirtyEvent makes replica B recompile and push to its own data planes immediately, instead of leaving them stale until B's periodic backstop fires.

func NewDistributedSignaler(local LocalSignaler, publisher cache.EventPublisher, logger *slog.Logger) *DistributedSignaler

func (s *DistributedSignaler) Signal(ctx context.Context)

type LocalSignaler ¶ added in v0.5.0

type LocalSignaler interface {
	Signal(ctx context.Context)
}

LocalSignaler triggers a recompile-and-broadcast on the current process.