followersexp

Documentation

Index

• func AssembleCursor(createdAt time.Time, actorDID string, rkey string) string
• func ParseCursor(cursor string) (time.Time, string, string, error)
• type ErrInvalidCursor
• type FollowersFeed
  • func NewFollowersFeed(ctx context.Context, feedActorDID string, gClient *graphdclient.Client, ...) (*FollowersFeed, []string, error)
  • func (f *FollowersFeed) Describe(ctx context.Context) ([]appbsky.FeedDescribeFeedGenerator_Feed, error)
  • func (f *FollowersFeed) GetPage(ctx context.Context, feed string, userDID string, limit int64, cursor string) ([]*appbsky.FeedDefs_SkeletonFeedPost, *string, error)
• type NotFoundError

Functions

func AssembleCursor

func AssembleCursor(createdAt time.Time, actorDID string, rkey string) string

func ParseCursor

func ParseCursor(cursor string) (time.Time, string, string, error)

ParseCursor takes a cursor string and returns the created_at, actor_did, and rkey <created_at>:<actor_did>:<rkey>

Types

type ErrInvalidCursor

type ErrInvalidCursor struct {
	// contains filtered or unexported fields
}

type FollowersFeed

type FollowersFeed struct {
	FeedActorDID string
	GraphD       *graphdclient.Client
	Redis        *redis.Client
	ShardDB      *sharddb.ShardDB
	Store        *store.Store
	// contains filtered or unexported fields
}

func NewFollowersFeed

func NewFollowersFeed(ctx context.Context, feedActorDID string, gClient *graphdclient.Client, rClient *redis.Client, shardDB *sharddb.ShardDB, store *store.Store) (*FollowersFeed, []string, error)

func (*FollowersFeed) Describe

func (f *FollowersFeed) Describe(ctx context.Context) ([]appbsky.FeedDescribeFeedGenerator_Feed, error)

func (*FollowersFeed) GetPage

func (f *FollowersFeed) GetPage(ctx context.Context, feed string, userDID string, limit int64, cursor string) ([]*appbsky.FeedDefs_SkeletonFeedPost, *string, error)

type NotFoundError

type NotFoundError struct {
	// contains filtered or unexported fields
}