file_storage

Documentation

Index

• func NewFileStorage(filename string, lockFilename ...string) (storage.Storage, error)
• type FileStorage
  • func (fs *FileStorage) Close() error
  • func (fs *FileStorage) GetMessages(offset uint64) ([]storage.Message, error)
  • func (fs *FileStorage) IgnoreMessages(messages []string, useOffset bool) error
  • func (fs *FileStorage) Send(msgs ...storage.Message) error
  • func (fs *FileStorage) UnignoreMessages()

Functions

func NewFileStorage

func NewFileStorage(filename string, lockFilename ...string) (storage.Storage, error)

NewFileStorage inits append-only file storage It takes two arguments: filename - path to a data file, lockFilename (optional) - path to a lock file

Types

type FileStorage

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

func (*FileStorage) Close

func (fs *FileStorage) Close() error

func (*FileStorage) GetMessages

func (fs *FileStorage) GetMessages(offset uint64) ([]storage.Message, error)

GetMessages returns a slice of messages from append-only data file with given offset

func (*FileStorage) IgnoreMessages

func (fs *FileStorage) IgnoreMessages(messages []string, useOffset bool) error

func (*FileStorage) Send

func (fs *FileStorage) Send(msgs ...storage.Message) error

func (*FileStorage) UnignoreMessages

func (fs *FileStorage) UnignoreMessages()