farcaster

package
v0.3.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 11, 2024 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSource

func NewSource(config *config.Module, checkpoint *engine.Checkpoint, databaseClient database.Client) (engine.Source, error)

Types

type Option added in v0.2.3

type Option struct {
	APIKey *string `json:"api_key" mapstructure:"api_key"`
}

func NewOption added in v0.2.3

func NewOption(options *config.Options) (*Option, error)

type State

type State struct {
	EventID           uint64 `json:"event_id"`           // Event ID that has been processed
	CastsFid          uint64 `json:"casts_fid"`          // Casts ID that has been processed in backfill casts
	CastsBackfill     bool   `json:"casts_backfill"`     // Casts backfill flag
	ReactionsFid      uint64 `json:"reactions_fid"`      // Reactions ID that has been processed in backfill reactions
	ReactionsBackfill bool   `json:"reactions_backfill"` // Reactions backfill flag
}

type Task

type Task struct {
	Network filter.Network
	Message farcaster.Message
}

func (Task) BuildFeed

func (t Task) BuildFeed(options ...schema.FeedOption) (*schema.Feed, error)

func (Task) GetNetwork

func (t Task) GetNetwork() filter.Network

func (Task) GetTimestamp

func (t Task) GetTimestamp() uint64

func (Task) ID

func (t Task) ID() string

func (Task) Validate

func (t Task) Validate() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL