geminipoller

Documentation

Index

• type CacheEntry
• type Poller
  • func NewPoller(conf poller.Config, geminiConfig *gemini.Config) (*Poller, error)
  • func (p *Poller) Datastore() datastore.Datastore[CacheEntry]
  • func (p *Poller) GeminiClient() *gemini.Client
  • func (p *Poller) GeminiConfig() gemini.Config
  • func (p *Poller) Start(ctx context.Context) error

Types

type CacheEntry

type CacheEntry struct {
	PollerId        []byte
	SymbolHash      []byte
	RecipientConfig poller.RecipientConfig
	Notifications   gemini.NotificationsConfig
	PollInterval    time.Duration
}

type Poller

type Poller struct {
	*poller.BasePoller
	// contains filtered or unexported fields
}

func NewPoller

func NewPoller(conf poller.Config, geminiConfig *gemini.Config) (*Poller, error)

func (*Poller) Datastore

func (p *Poller) Datastore() datastore.Datastore[CacheEntry]

func (*Poller) GeminiClient

func (p *Poller) GeminiClient() *gemini.Client

func (*Poller) GeminiConfig

func (p *Poller) GeminiConfig() gemini.Config

func (*Poller) Start

func (p *Poller) Start(ctx context.Context) error