memory

Documentation

Index

• type Storage
  • func NewStorage() *Storage
  • func (s *Storage) GetCurrSeqNum(pk string) (int, error)
  • func (s *Storage) GetNextSeqNum(pk string) (int, error)
  • func (s *Storage) Messages(pk string, msgSeqNumFrom, msgSeqNumTo int) ([]simplefixgo.SendingMessage, error)
  • func (s *Storage) ResetSeqNum(pk string) error
  • func (s *Storage) Save(pk string, msg simplefixgo.SendingMessage, msgSeqNum int) error

Types

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

Storage is used to store the most recent messages.

func NewStorage

func NewStorage() *Storage

NewStorage is a constructor for creation of a new in-memory Storage.

func (*Storage) GetCurrSeqNum

func (s *Storage) GetCurrSeqNum(pk string) (int, error)

func (*Storage) GetNextSeqNum

func (s *Storage) GetNextSeqNum(pk string) (int, error)

func (*Storage) Messages

func (s *Storage) Messages(pk string, msgSeqNumFrom, msgSeqNumTo int) ([]simplefixgo.SendingMessage, error)

Messages returns a message list, in a sequential order (starting with msgSeqNumFrom and ending with msgSeqNumTo).

func (*Storage) ResetSeqNum

func (s *Storage) ResetSeqNum(pk string) error

func (*Storage) Save

func (s *Storage) Save(pk string, msg simplefixgo.SendingMessage, msgSeqNum int) error

Save saves a message with seq number to storage