storage

Documentation

Index

• type ChannelState
• type Storage
  • func NewStorage(dataDir string) (*Storage, error)
  • func (s *Storage) GenerateBloomFileName(feedURL string, channel string) string
  • func (s *Storage) GetBloomFilePath(feedURL string, channel string) string
  • func (s *Storage) GetLastUpdated(feedURL string, channel string) time.Time
  • func (s *Storage) IsItemSeen(feedURL, feedName, channel, itemID string) bool
  • func (s *Storage) MarkItemSeen(feedURL, feedName, channel, itemID string) error

Types

type ChannelState

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

type Storage

type Storage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewStorage

func NewStorage(dataDir string) (*Storage, error)

rss发布状态的存储桶

func (*Storage) GenerateBloomFileName

func (s *Storage) GenerateBloomFileName(feedURL string, channel string) string

生成布隆过滤器的文件名

func (*Storage) GetBloomFilePath

func (s *Storage) GetBloomFilePath(feedURL string, channel string) string

GetBloomFilePath 获取bloom过滤器的文件路径

func (*Storage) GetLastUpdated

func (s *Storage) GetLastUpdated(feedURL string, channel string) time.Time

func (*Storage) IsItemSeen

func (s *Storage) IsItemSeen(feedURL, feedName, channel, itemID string) bool

检查item是否已经被处理

func (*Storage) MarkItemSeen

func (s *Storage) MarkItemSeen(feedURL, feedName, channel, itemID string) error

标记item为已处理