farcaster

Documentation

Index

• Variables
• func BundlerKind(msg *pb.MessageData) (s string)
• func Firehose(ctx context.T, cancel context.F, wg_parent *sync.WaitGroup, endpoints []string, ...)
• func MessageToBundleItem(msg *pb.Message) (bundle *types.BundleItem, err error)

Variables

var (
	Urls = []string{
		"hub.pinata.cloud",
		"api.hub.wevm.dev",
		"hoyt.farcaster.xyz:2283",
		"lamia.farcaster.xyz:2283",
		"api.farcasthub.com:2283",
		"nemes.farcaster.xyz:2283",
		"hub.farcaster.standardcrypto.vc:2281",
		"hoyt.farcaster.xyz:2281",
		"lamia.farcaster.xyz:2281",
		"api.farcasthub.com:2281",
		"nemes.farcaster.xyz:2281",
		"hub.farcaster.standardcrypto.vc:2282",
		"hoyt.farcaster.xyz:2282",
		"lamia.farcaster.xyz:2282",
		"api.farcasthub.com:2282",
		"nemes.farcaster.xyz:2282",
		"hub.farcaster.standardcrypto.vc:2283",
	}
)

Functions

func BundlerKind

func BundlerKind(msg *pb.MessageData) (s string)

func Firehose

func Firehose(
	ctx context.T,
	cancel context.F,
	wg_parent *sync.WaitGroup,
	endpoints []string,
	fn func(bundle *types.BundleItem) (err error),
)

Firehose function connects to multiple hubs concurrently and streams BundleItems

func MessageToBundleItem

func MessageToBundleItem(msg *pb.Message) (bundle *types.BundleItem, err error)