storage

Documentation

Index

• type Message
  • func (m *Message) Bytes() []byte
  • func (m *Message) Verify(pubKey ed25519.PublicKey) bool
• type Storage

Types

type Message

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"`
}

func (*Message) Bytes

func (m *Message) Bytes() []byte

func (*Message) Verify

func (m *Message) Verify(pubKey ed25519.PublicKey) bool

type Storage

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()
}