shadow

type BalanceStrategyCoPartitioned struct{}

type DeviceState struct {
	ID    string
	State DeviceStateMessage
}

type DeviceStateDB struct {
	ID              string
	ReportedVersion uint64
	ReportedState   postgres.Jsonb
	DesiredVersion  uint64
	DesiredState    postgres.Jsonb
}

type DeviceStateMessage struct {
	Version   uint64
	State     json.RawMessage
	Timestamp time.Time
}

type Repo interface {
	SetReported(DeviceState) (err error)
	GetReported(id string) (DeviceState, error)
	SetDesired(DeviceState) (err error)
	GetDesired(id string) (DeviceState, error)
}

type Server struct {
	Repo         Repo
	Producer     sarama.SyncProducer // Sync producer, we want to guarantee execution
	ProduceTopic string
	Log          *zap.Logger

	PubSub *pubsub.PubSub
}

type StateMerger struct {
	SourceTopic    string // Incoming ticks
	MergedTopic    string // Full state with version
	RealDeltaTopic string // Deltas for each full state transition, with version

	ChangelogConsumerClient sarama.Client
	ChangelogProducerClient sarama.Client
	// contains filtered or unexported fields
}