Documentation ¶
Index ¶
- func MustDecodeENR(enrStr string) *enode.Node
- func MustDecodeMultiaddress(multiaddrsStr string) *multiaddr.Multiaddr
- 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, pubsubTopic string, 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)
- 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(pubsubTopic, contentTopic string) error
- func (d *Database) Mailservers() ([]Mailserver, error)
- func (d *Database) RequestGaps(chatID string) ([]MailserverRequestGap, error)
- func (d *Database) ResetLastRequest(pubsubTopic, contentTopic string) error
- func (d *Database) SetTopics(filters []*transport.Filter) (err error)
- func (d *Database) Topics() ([]MailserverTopic, error)
- type Mailserver
- type MailserverRequestGap
- type MailserverTopic
- type Service
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MustDecodeENR ¶ added in v0.185.0
func MustDecodeMultiaddress ¶ added in v0.185.0
func MustDecodeMultiaddress(multiaddrsStr string) *multiaddr.Multiaddr
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)
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 Mailserver struct { ID string `json:"id"` Name string `json:"name"` Custom bool `json:"custom"` ENR *enode.Node `json:"enr"` Addr *multiaddr.Multiaddr `json:"addr"` // Deprecated: only used with WakuV1 Password string `json:"password,omitempty"` Fleet string `json:"fleet"` FailedRequests uint `json:"-"` }
func DefaultMailservers ¶ added in v0.96.0
func DefaultMailservers() []Mailserver
func DefaultMailserversByFleet ¶ added in v0.171.40
func DefaultMailserversByFleet(fleet string) []Mailserver
type MailserverRequestGap ¶
type MailserverTopic ¶
Click to show internal directories.
Click to hide internal directories.