storage

type Message struct {
	ID            string `json:"id"`
	DkgRoundID    string `json:"dkg_round_id"`
	Offset        uint64 `json:"offset"`
	Event         string `json:"event"`
	Data          []byte `json:"data"`
	Signature     []byte `json:"signature"`
	SenderAddr    string `json:"sender"`
	RecipientAddr string `json:"recipient"`
}

type Storage interface {
	// Send is expected to be an atomic operation.
	Send(messages ...Message) error
	GetMessages(offset uint64) ([]Message, error)
	Close() error
	IgnoreMessages(messages []string, useOffset bool) error
	UnignoreMessages()
}