db

type ChangeReceiver func(logId string, records []consensus.Record)

type Config struct {
	Connect       string `yaml:"connect"`
	Database      string `yaml:"database"`
	LogCollection string `yaml:"logCollection"`
}

type Service interface {
	// AddLog adds new log db
	AddLog(ctx context.Context, log consensus.Log) (err error)
	// DeleteLog deletes the log
	DeleteLog(ctx context.Context, logId string) error
	// AddRecord adds new record to existing log
	// returns consensuserr.ErrConflict if record didn't match or log not found
	AddRecord(ctx context.Context, logId string, record consensus.Record) (err error)
	// FetchLog gets log by id
	FetchLog(ctx context.Context, logId, afterRecordId string) (log consensus.Log, err error)
	// SetChangeReceiver sets the receiver for updates, it must be called before app.Run stage
	SetChangeReceiver(receiver ChangeReceiver) (err error)
	// SetDeletionId sets the last deleted log id
	SetDeletionId(ctx context.Context, lastId string) (err error)
	// GetDeletionId gets the last deletion log id
	GetDeletionId(ctx context.Context) (lastId string, err error)
	app.ComponentRunnable
}