state

type ActiveBoundary struct {
	StartBlockNumber uint64 `yaml:"start_block_number"  json:"start_block_number"`
	EndBlockNumber   uint64 `yaml:"end_block_number"  json:"end_block_number"`
}

type BlockState struct {
	ID     string `yaml:"id" json:"id"`
	Number uint64 `yaml:"number" json:"number"`
}

type FileState struct {
	Cursor         string         `yaml:"cursor" json:"cursor"`
	Block          BlockState     `yaml:"block" json:"block"`
	ActiveBoundary ActiveBoundary `yaml:"active_boundary" json:"active_boundary"`

	// StartedAt is the time this process was launching initially without accounting to any restart, once set, this
	// value, it's never re-written (unless the file does not exist anymore).
	StartedAt time.Time `yaml:"started_at,omitempty" json:"started_at,omitempty"`
	// RestartedAt is the time this process was last launched meaning it's reset each time the process start. This value
	// in contrast to `StartedAt` change over time each time the process is restarted.
	RestartedAt time.Time `yaml:"restarted_at,omitempty" json:"restarted_at,omitempty"`
}

type FileStateStore struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

type Saveable interface {
	Save() error
	GetUploadeable() writer.Uploadeable
}

type Store interface {
	Start(context.Context)
	Close()
	NewBoundary(*bstream.Range)
	ReadCursor(context.Context) (*sink.Cursor, error)
	SetCursor(*sink.Cursor)
	GetState() (Saveable, error)
	UploadCursor(state Saveable)
	Shutdown(error)
	OnTerminating(func(error))
}