db

Documentation

Index

• Variables
• type Database
  • func NewSQLite() Database
• type Feed
• type SQLite
  • func (d *SQLite) AddFeed(name, repo, filter, messagePattern string) (int, error)
  • func (db *SQLite) AddMessagesToResentQueue(messages []*types.NotificationMessage) error
  • func (d *SQLite) AddSubscribtion(endpoint, url, filter string, chatID int64) error
  • func (d *SQLite) GetEndpointInfo(endpoint, url, filter string) ([]int64, error)
  • func (d *SQLite) GetFeed(name string) (*Feed, error)
  • func (d *SQLite) GetLastTag(url, filter string) string
  • func (d *SQLite) GetLastUpdateTime(url, filter string) time.Time
  • func (db *SQLite) GetMessagesFromResentQueue() ([]*types.NotificationMessage, error)
  • func (d *SQLite) GetNotificationMethods(url, filter string) ([]string, error)
  • func (d *SQLite) ListFeeds() ([]*Feed, error)
  • func (d *SQLite) RemoveFeed(name, repo, filter, messagePattern string) error
  • func (d *SQLite) RemoveSubscribtion(endpoint, url, filter string, chatID int64) error
  • func (d *SQLite) UpdateChatID(oldChatID, newChatID int64) error
  • func (d *SQLite) UpdateLastUpdateTime(url, filter, tag string, t time.Time)

Variables

var ErrAlreadyExists error = fmt.Errorf("already exists")

Types

type Database

type Database interface {
	GetLastUpdateTime(url, filter string) time.Time
	GetLastTag(url, filter string) string
	UpdateLastUpdateTime(url, filter, tag string, t time.Time)

	AddFeed(name, repo, filter, messagePattern string) (int, error)
	GetFeed(name string) (*Feed, error)
	ListFeeds() ([]*Feed, error)
	RemoveFeed(name, repo, filter, messagePattern string) error

	// Subscriptions
	AddSubscribtion(endpoint, url, filter string, chatID int64) error
	RemoveSubscribtion(endpoint, url, filter string, chatID int64) error

	// Maintenance
	UpdateChatID(oldChatID, newChatID int64) error

	// Notification methods
	GetNotificationMethods(url, filter string) ([]string, error)

	// Endpoints
	GetEndpointInfo(endpoint, url, filter string) ([]int64, error)

	// Resend Queue
	AddMessagesToResentQueue(messages []*types.NotificationMessage) error
	GetMessagesFromResentQueue() ([]*types.NotificationMessage, error)
}

func NewSQLite

func NewSQLite() Database

type Feed

type Feed struct {
	Id             int
	Repo           string
	Filter         string
	Name           string
	MessagePattern string
}

type SQLite

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

func (*SQLite) AddFeed

func (d *SQLite) AddFeed(name, repo, filter, messagePattern string) (int, error)

func (*SQLite) AddMessagesToResentQueue

func (db *SQLite) AddMessagesToResentQueue(messages []*types.NotificationMessage) error

func (*SQLite) AddSubscribtion

func (d *SQLite) AddSubscribtion(endpoint, url, filter string, chatID int64) error

func (*SQLite) GetEndpointInfo

func (d *SQLite) GetEndpointInfo(endpoint, url, filter string) ([]int64, error)

func (*SQLite) GetFeed

func (d *SQLite) GetFeed(name string) (*Feed, error)

func (*SQLite) GetLastTag

func (d *SQLite) GetLastTag(url, filter string) string

GetLastTag - gets Last Tag

func (*SQLite) GetLastUpdateTime

func (d *SQLite) GetLastUpdateTime(url, filter string) time.Time

GetLastUpdateTime - gets Last Update Time

func (*SQLite) GetMessagesFromResentQueue

func (db *SQLite) GetMessagesFromResentQueue() ([]*types.NotificationMessage, error)

func (*SQLite) GetNotificationMethods

func (d *SQLite) GetNotificationMethods(url, filter string) ([]string, error)

func (*SQLite) ListFeeds

func (d *SQLite) ListFeeds() ([]*Feed, error)

func (*SQLite) RemoveFeed

func (d *SQLite) RemoveFeed(name, repo, filter, messagePattern string) error

func (*SQLite) RemoveSubscribtion

func (d *SQLite) RemoveSubscribtion(endpoint, url, filter string, chatID int64) error

func (*SQLite) UpdateChatID

func (d *SQLite) UpdateChatID(oldChatID, newChatID int64) error

func (*SQLite) UpdateLastUpdateTime

func (d *SQLite) UpdateLastUpdateTime(url, filter, tag string, t time.Time)