Documentation
¶
Index ¶
- Variables
- type 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrAlreadyExists error = fmt.Errorf("already exists")
Functions ¶
This section is empty.
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)
}
type SQLite ¶
type SQLite struct {
// contains filtered or unexported fields
}
func (*SQLite) AddMessagesToResentQueue ¶ added in v0.0.2
func (db *SQLite) AddMessagesToResentQueue(messages []*types.NotificationMessage) error
func (*SQLite) AddSubscribtion ¶
func (*SQLite) GetEndpointInfo ¶
func (*SQLite) GetLastTag ¶
GetLastTag - gets Last Tag
func (*SQLite) GetLastUpdateTime ¶
GetLastUpdateTime - gets Last Update Time
func (*SQLite) GetMessagesFromResentQueue ¶ added in v0.0.2
func (db *SQLite) GetMessagesFromResentQueue() ([]*types.NotificationMessage, error)
func (*SQLite) GetNotificationMethods ¶
func (*SQLite) RemoveFeed ¶ added in v0.0.2
func (*SQLite) RemoveSubscribtion ¶
func (*SQLite) UpdateChatID ¶ added in v0.0.2
Click to show internal directories.
Click to hide internal directories.