Documentation
¶
Index ¶
- type API
- func (a *API) AddChatRequestRange(ctx context.Context, req ChatRequestRange) error
- func (a *API) AddChatRequestRanges(ctx context.Context, reqs []ChatRequestRange) error
- func (a *API) AddMailserver(ctx context.Context, m Mailserver) error
- func (a *API) AddMailserverRequestGaps(ctx context.Context, gaps []MailserverRequestGap) error
- func (a *API) AddMailserverTopic(ctx context.Context, topic MailserverTopic) error
- func (a *API) AddMailserverTopics(ctx context.Context, topics []MailserverTopic) error
- func (a *API) DeleteChatRequestRange(ctx context.Context, chatID string) error
- func (a *API) DeleteMailserver(ctx context.Context, id string) error
- func (a *API) DeleteMailserverRequestGaps(ctx context.Context, ids []string) error
- func (a *API) DeleteMailserverRequestGapsByChatID(ctx context.Context, chatID string) error
- func (a *API) DeleteMailserverTopic(ctx context.Context, topic string) error
- func (a *API) GetChatRequestRanges(ctx context.Context) ([]ChatRequestRange, error)
- func (a *API) GetMailserverRequestGaps(ctx context.Context, chatID string) ([]MailserverRequestGap, error)
- func (a *API) GetMailserverTopics(ctx context.Context) ([]MailserverTopic, error)
- func (a *API) GetMailservers(ctx context.Context) ([]Mailserver, error)
- func (a *API) MultiAddressPing(ctx context.Context, pq PingQuery) ([]*PingResult, error)
- func (a *API) Ping(ctx context.Context, pq PingQuery) ([]*PingResult, error)
- type ChatRequestRange
- type Database
- func (d *Database) Add(mailserver Mailserver) error
- func (d *Database) AddChatRequestRange(req ChatRequestRange) error
- func (d *Database) AddChatRequestRanges(reqs []ChatRequestRange) (err error)
- func (d *Database) AddGaps(gaps []MailserverRequestGap) error
- func (d *Database) AddTopic(topic MailserverTopic) error
- func (d *Database) AddTopics(topics []MailserverTopic) (err error)
- func (d *Database) ChatRequestRanges() ([]ChatRequestRange, error)
- func (d *Database) Delete(id string) error
- func (d *Database) DeleteChatRequestRange(chatID string) error
- func (d *Database) DeleteGaps(ids []string) error
- func (d *Database) DeleteGapsByChatID(chatID string) error
- func (d *Database) DeleteTopic(topic string) error
- func (d *Database) Mailservers() ([]Mailserver, error)
- func (d *Database) RequestGaps(chatID string) ([]MailserverRequestGap, error)
- func (d *Database) ResetLastRequest(topic string) error
- func (d *Database) SetTopics(filters []*transport.Filter) (err error)
- func (d *Database) Topics() ([]MailserverTopic, error)
- type Mailserver
- type MailserverRequestGap
- type MailserverTopic
- type PingQuery
- type PingResult
- type Service
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type API ¶
type API struct {
// contains filtered or unexported fields
}
API is class with methods available over RPC.
func (*API) AddChatRequestRange ¶
func (a *API) AddChatRequestRange(ctx context.Context, req ChatRequestRange) error
func (*API) AddChatRequestRanges ¶ added in v0.69.0
func (a *API) AddChatRequestRanges(ctx context.Context, reqs []ChatRequestRange) error
func (*API) AddMailserver ¶
func (a *API) AddMailserver(ctx context.Context, m Mailserver) error
func (*API) AddMailserverRequestGaps ¶
func (a *API) AddMailserverRequestGaps(ctx context.Context, gaps []MailserverRequestGap) error
func (*API) AddMailserverTopic ¶
func (a *API) AddMailserverTopic(ctx context.Context, topic MailserverTopic) error
func (*API) AddMailserverTopics ¶ added in v0.69.0
func (a *API) AddMailserverTopics(ctx context.Context, topics []MailserverTopic) error
func (*API) DeleteChatRequestRange ¶
func (*API) DeleteMailserverRequestGaps ¶
func (*API) DeleteMailserverRequestGapsByChatID ¶
func (*API) DeleteMailserverTopic ¶
func (*API) GetChatRequestRanges ¶
func (a *API) GetChatRequestRanges(ctx context.Context) ([]ChatRequestRange, error)
func (*API) GetMailserverRequestGaps ¶
func (*API) GetMailserverTopics ¶
func (a *API) GetMailserverTopics(ctx context.Context) ([]MailserverTopic, error)
func (*API) GetMailservers ¶
func (a *API) GetMailservers(ctx context.Context) ([]Mailserver, error)
func (*API) MultiAddressPing ¶ added in v0.88.4
type ChatRequestRange ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
Database sql wrapper for operations with mailserver objects.
func (*Database) Add ¶
func (d *Database) Add(mailserver Mailserver) error
func (*Database) AddChatRequestRange ¶
func (d *Database) AddChatRequestRange(req ChatRequestRange) error
func (*Database) AddChatRequestRanges ¶ added in v0.69.0
func (d *Database) AddChatRequestRanges(reqs []ChatRequestRange) (err error)
func (*Database) AddGaps ¶
func (d *Database) AddGaps(gaps []MailserverRequestGap) error
func (*Database) AddTopic ¶
func (d *Database) AddTopic(topic MailserverTopic) error
func (*Database) AddTopics ¶ added in v0.69.0
func (d *Database) AddTopics(topics []MailserverTopic) (err error)
func (*Database) ChatRequestRanges ¶
func (d *Database) ChatRequestRanges() ([]ChatRequestRange, error)
func (*Database) DeleteChatRequestRange ¶
func (*Database) DeleteGaps ¶
func (*Database) DeleteGapsByChatID ¶
func (*Database) DeleteTopic ¶
func (*Database) Mailservers ¶
func (d *Database) Mailservers() ([]Mailserver, error)
func (*Database) RequestGaps ¶
func (d *Database) RequestGaps(chatID string) ([]MailserverRequestGap, error)
func (*Database) ResetLastRequest ¶ added in v0.92.4
func (*Database) SetTopics ¶ added in v0.69.0
SetTopics deletes all topics excepts the one set, or upsert those if missing
func (*Database) Topics ¶
func (d *Database) Topics() ([]MailserverTopic, error)
type Mailserver ¶
type MailserverRequestGap ¶
type MailserverTopic ¶
type PingResult ¶
type PingResult struct { Address string `json:"address"` RTTMs *int `json:"rttMs"` Err *string `json:"error"` }
func (*PingResult) Update ¶
func (pr *PingResult) Update(rttMs int, err error)
Click to show internal directories.
Click to hide internal directories.