walk

Documentation

Index

• func WalkTweets(ctx context.Context, opts *WalkOptions, tweets_fh io.Reader)
• func WalkTweetsWithCallback(ctx context.Context, opts *WalkWithCallbackOptions, tweets_fh io.Reader) error
• type WalkOptions
• type WalkTweetsCallbackFunc
• type WalkWithCallbackOptions

Functions

func WalkTweets

func WalkTweets(ctx context.Context, opts *WalkOptions, tweets_fh io.Reader)

func WalkTweetsWithCallback

func WalkTweetsWithCallback(ctx context.Context, opts *WalkWithCallbackOptions, tweets_fh io.Reader) error

Types

type WalkOptions

type WalkOptions struct {
	TweetChannel chan []byte
	ErrorChannel chan error
	DoneChannel  chan bool
	QuerySet     *query.QuerySet
}

type WalkTweetsCallbackFunc

type WalkTweetsCallbackFunc func(ctx context.Context, tweet []byte) error

type WalkWithCallbackOptions

type WalkWithCallbackOptions struct {
	Callback WalkTweetsCallbackFunc
	QuerySet *query.QuerySet
}