sharddb

Documentation

Index

• Variables
• func GetBucketFromRKey(rkey string) (int, error)
• func GetHighestRKeyForBucket(bucket int) string
• func GetLowestRKeyForBucket(bucket int) string
• type Post
• type ShardDB
  • func NewShardDB(ctx context.Context, scyllaNodes []string, logger *slog.Logger) (*ShardDB, error)
  • func (s *ShardDB) CreatePostTable(ctx context.Context) error
  • func (s *ShardDB) DeletePost(ctx context.Context, actorDID, rkey string, indexedAt time.Time, bucket int) error
  • func (s *ShardDB) GetPostMetas(ctx context.Context, bucket, limit int, cursor time.Time) ([]*Post, time.Time, error)
  • func (s *ShardDB) GetPosts(ctx context.Context, bucket, limit int, cursor time.Time) ([]*Post, time.Time, error)
  • func (s *ShardDB) InsertPost(ctx context.Context, post Post) error

Variables

var QueryDuration = promauto.NewHistogramVec(prometheus.HistogramOpts{
	Name: "sharddb_query_duration_seconds",
	Help: "Duration of sharddb queries",
}, []string{"query_name", "status"})

Functions

func GetBucketFromRKey

func GetBucketFromRKey(rkey string) (int, error)

func GetHighestRKeyForBucket

func GetHighestRKeyForBucket(bucket int) string

func GetLowestRKeyForBucket

func GetLowestRKeyForBucket(bucket int) string

Types

type Post

type Post struct {
	ActorDID  string
	Rkey      string
	IndexedAt time.Time
	Bucket    int
	Raw       []byte
	Langs     []string
	Tags      []string
	HasMedia  bool
	IsReply   bool
}

type ShardDB

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

func NewShardDB

func NewShardDB(ctx context.Context, scyllaNodes []string, logger *slog.Logger) (*ShardDB, error)

func (*ShardDB) CreatePostTable

func (s *ShardDB) CreatePostTable(ctx context.Context) error

func (*ShardDB) DeletePost

func (s *ShardDB) DeletePost(ctx context.Context, actorDID, rkey string, indexedAt time.Time, bucket int) error

func (*ShardDB) GetPostMetas

func (s *ShardDB) GetPostMetas(ctx context.Context, bucket, limit int, cursor time.Time) ([]*Post, time.Time, error)

GetPostMetas returns a page of posts without the raw content

func (*ShardDB) GetPosts

func (s *ShardDB) GetPosts(ctx context.Context, bucket, limit int, cursor time.Time) ([]*Post, time.Time, error)

func (*ShardDB) InsertPost

func (s *ShardDB) InsertPost(ctx context.Context, post Post) error