app

Documentation

Index

• type FeedStats
• type ItemState
• type ProcessedItem
  • func NewProcessedItemFromBytes(byt []byte) (*ProcessedItem, error)
  • func (si *ProcessedItem) Key() []byte
  • func (si *ProcessedItem) ToBytes() ([]byte, error)
• type WebhookStats

Types

type FeedStats

type FeedStats struct {
	Name          string
	ErrorCount    int
	ReceivedCount int
	ReceivedLast  time.Time
}

type ItemState

type ItemState uint

const (
	StateProcessed ItemState = iota
	StateUpdated
	StateNew
)

type ProcessedItem

type ProcessedItem struct {
	ID        string
	Published time.Time
}

ProcessedItem represents a sent item

func NewProcessedItemFromBytes

func NewProcessedItemFromBytes(byt []byte) (*ProcessedItem, error)

func (*ProcessedItem) Key

func (si *ProcessedItem) Key() []byte

func (*ProcessedItem) ToBytes

func (si *ProcessedItem) ToBytes() ([]byte, error)

type WebhookStats

type WebhookStats struct {
	Name      string
	SentCount int
	SentLast  time.Time
}