store

Documentation

Index

• type File
  • func NewFile(baseDir string, maxAge time.Duration) *File
  • func (f *File) GetAll(receiverKey []byte) ([]*pb.DMSMessage, error)
  • func (f *File) GetNext(receiverKey []byte) (*pb.DMSMessage, error)
  • func (f *File) Remove(msg *pb.DMSMessage, receiverKey []byte) error
  • func (f *File) Save(msg *pb.DMSMessage, receiverKey []byte) error
• type Store

Types

type File

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

func NewFile

func NewFile(baseDir string, maxAge time.Duration) *File

func (*File) GetAll

func (f *File) GetAll(receiverKey []byte) ([]*pb.DMSMessage, error)

func (*File) GetNext

func (f *File) GetNext(receiverKey []byte) (*pb.DMSMessage, error)

func (*File) Remove

func (f *File) Remove(msg *pb.DMSMessage, receiverKey []byte) error

func (*File) Save

func (f *File) Save(msg *pb.DMSMessage, receiverKey []byte) error

type Store

type Store interface {
	// Save saves a new message using the receiver key.
	Save(msg *pb.DMSMessage, receiverKey []byte) error

	// Get next returns next message available for this receiver.
	GetNext(receiver []byte) (*pb.DMSMessage, error)

	// Get all returns all messages available for this receiver.
	GetAll(receiver []byte) ([]*pb.DMSMessage, error)

	// Remove removes the message from the local storage.
	Remove(msg *pb.DMSMessage, receiverKey []byte) error
}

Store represents local store for DMSMessages.