store

Documentation

Index

• type File
  • func NewFile(baseDir string) *File
  • 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) *File

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(msg *pb.DMSMessage, receiverKey []byte) error
	GetNext(receiver []byte) (*pb.DMSMessage, error)
	Remove(msg *pb.DMSMessage, receiverKey []byte) error
}