Versions in this module Expand all Collapse all v0 v0.3.0 May 23, 2024 Changes in this version + const SeenPostShardSeconds + func GetRoomHash(room string) []byte + func GetSeenPostShard32(seen time.Time) uint32 + func GetSeenPostShardSource(seen time.Time) uint + func GetTopics() []db.Object + func IsSeenPostSameShardWindow(a, b time.Time) bool + func ListenAddrFolloweds(ctx context.Context, followAddrs [][25]byte) (chan *AddrFollowed, error) + func ListenAddrFollows(ctx context.Context, addrs [][25]byte) (chan *AddrFollow, error) + func ListenAddrNames(ctx context.Context, addrs [][25]byte) (chan *AddrName, error) + func ListenAddrProfilePics(ctx context.Context, addrs [][25]byte) (chan *AddrProfilePic, error) + func ListenAddrProfiles(ctx context.Context, addrs [][25]byte) (chan *AddrProfile, error) + func ListenAddrRoomFollows(ctx context.Context, addrs [][25]byte) (chan *AddrRoomFollow, error) + func ListenPostChildren(ctx context.Context, postTxHashes [][32]byte) (chan *PostChild, error) + func ListenPostLikes(ctx context.Context, postTxHashes [][32]byte) (chan *PostLike, error) + func ListenPosts(ctx context.Context) (chan *Post, error) + func ListenRoomPosts(ctx context.Context, rooms []string) (chan *RoomPost, error) + type AddrFollow struct + Addr [25]byte + FollowAddr [25]byte + Seen time.Time + TxHash [32]byte + Unfollow bool + func GetAddrFollows(ctx context.Context, addrs [][25]byte) ([]*AddrFollow, error) + func GetAddrFollowsSingle(ctx context.Context, addr [25]byte, start time.Time) ([]*AddrFollow, error) + func (f *AddrFollow) Deserialize(data []byte) + func (f *AddrFollow) GetShardSource() uint + func (f *AddrFollow) GetTopic() string + func (f *AddrFollow) GetUid() []byte + func (f *AddrFollow) Serialize() []byte + func (f *AddrFollow) SetUid(uid []byte) + type AddrFollowed struct + Addr [25]byte + FollowAddr [25]byte + Seen time.Time + TxHash [32]byte + Unfollow bool + func GetAddrFolloweds(ctx context.Context, followAddresses [][25]byte) ([]*AddrFollowed, error) + func GetAddrFollowedsSingle(ctx context.Context, followAddr [25]byte, start time.Time) ([]*AddrFollowed, error) + func (f *AddrFollowed) Deserialize(data []byte) + func (f *AddrFollowed) GetShardSource() uint + func (f *AddrFollowed) GetTopic() string + func (f *AddrFollowed) GetUid() []byte + func (f *AddrFollowed) Serialize() []byte + func (f *AddrFollowed) SetUid(uid []byte) + type AddrLike struct + Addr [25]byte + LikeTxHash [32]byte + PostTxHash [32]byte + Seen time.Time + func (l *AddrLike) Deserialize(data []byte) + func (l *AddrLike) GetShardSource() uint + func (l *AddrLike) GetTopic() string + func (l *AddrLike) GetUid() []byte + func (l *AddrLike) Serialize() []byte + func (l *AddrLike) SetUid(uid []byte) + type AddrName struct + Addr [25]byte + Name string + Seen time.Time + TxHash [32]byte + func GetAddrName(ctx context.Context, addr [25]byte) (*AddrName, error) + func (n *AddrName) Deserialize(data []byte) + func (n *AddrName) GetShardSource() uint + func (n *AddrName) GetTopic() string + func (n *AddrName) GetUid() []byte + func (n *AddrName) Serialize() []byte + func (n *AddrName) SetUid(uid []byte) + type AddrPost struct + Addr [25]byte + Seen time.Time + TxHash [32]byte + func GetAddrPosts(ctx context.Context, addrs [][25]byte, newest bool) ([]*AddrPost, error) + func GetSingleAddrPosts(ctx context.Context, addr [25]byte, newest bool, start time.Time) ([]*AddrPost, error) + func (p *AddrPost) Deserialize([]byte) + func (p *AddrPost) GetShardSource() uint + func (p *AddrPost) GetTopic() string + func (p *AddrPost) GetUid() []byte + func (p *AddrPost) Serialize() []byte + func (p *AddrPost) SetUid(uid []byte) + type AddrProfile struct + Addr [25]byte + Profile string + Seen time.Time + TxHash [32]byte + func GetAddrProfile(ctx context.Context, addr [25]byte) (*AddrProfile, error) + func (p *AddrProfile) Deserialize(data []byte) + func (p *AddrProfile) GetShardSource() uint + func (p *AddrProfile) GetTopic() string + func (p *AddrProfile) GetUid() []byte + func (p *AddrProfile) Serialize() []byte + func (p *AddrProfile) SetUid(uid []byte) + type AddrProfilePic struct + Addr [25]byte + Pic string + Seen time.Time + TxHash [32]byte + func GetAddrProfilePic(ctx context.Context, addr [25]byte) (*AddrProfilePic, error) + func (p *AddrProfilePic) Deserialize(data []byte) + func (p *AddrProfilePic) GetShardSource() uint + func (p *AddrProfilePic) GetTopic() string + func (p *AddrProfilePic) GetUid() []byte + func (p *AddrProfilePic) Serialize() []byte + func (p *AddrProfilePic) SetUid(uid []byte) + type AddrRoomFollow struct + Addr [25]byte + Room string + Seen time.Time + TxHash [32]byte + Unfollow bool + func GetAddrRoomFollows(ctx context.Context, addrs [][25]byte) ([]*AddrRoomFollow, error) + func (f *AddrRoomFollow) Deserialize(data []byte) + func (f *AddrRoomFollow) GetShardSource() uint + func (f *AddrRoomFollow) GetTopic() string + func (f *AddrRoomFollow) GetUid() []byte + func (f *AddrRoomFollow) Serialize() []byte + func (f *AddrRoomFollow) SetUid(uid []byte) + type LikeTip struct + LikeTxHash [32]byte + Tip int64 + func GetLikeTips(likeTxHashes [][32]byte) ([]*LikeTip, error) + func (t *LikeTip) Deserialize(data []byte) + func (t *LikeTip) GetShardSource() uint + func (t *LikeTip) GetTopic() string + func (t *LikeTip) GetUid() []byte + func (t *LikeTip) Serialize() []byte + func (t *LikeTip) SetUid(uid []byte) + type Post struct + Addr [25]byte + Post string + TxHash [32]byte + func GetPost(ctx context.Context, txHash [32]byte) (*Post, error) + func GetPosts(ctx context.Context, txHashes [][32]byte) ([]*Post, error) + func (p *Post) Deserialize(data []byte) + func (p *Post) GetShardSource() uint + func (p *Post) GetTopic() string + func (p *Post) GetUid() []byte + func (p *Post) Serialize() []byte + func (p *Post) SetUid(uid []byte) + type PostChild struct + ChildTxHash [32]byte + PostTxHash [32]byte + func GetPostChildren(ctx context.Context, postTxHash [32]byte) ([]*PostChild, error) + func (c *PostChild) Deserialize([]byte) + func (c *PostChild) GetShardSource() uint + func (c *PostChild) GetTopic() string + func (c *PostChild) GetUid() []byte + func (c *PostChild) Serialize() []byte + func (c *PostChild) SetUid(uid []byte) + type PostLike struct + Addr [25]byte + LikeTxHash [32]byte + PostTxHash [32]byte + Seen time.Time + func GetPostLikes(postTxHashes [][32]byte) ([]*PostLike, error) + func (l *PostLike) Deserialize(data []byte) + func (l *PostLike) GetShardSource() uint + func (l *PostLike) GetTopic() string + func (l *PostLike) GetUid() []byte + func (l *PostLike) Serialize() []byte + func (l *PostLike) SetUid(uid []byte) + type PostParent struct + ParentTxHash [32]byte + PostTxHash [32]byte + func GetPostParent(ctx context.Context, postTxHash [32]byte) (*PostParent, error) + func (p *PostParent) Deserialize(data []byte) + func (p *PostParent) GetShardSource() uint + func (p *PostParent) GetTopic() string + func (p *PostParent) GetUid() []byte + func (p *PostParent) Serialize() []byte + func (p *PostParent) SetUid(uid []byte) + type PostRoom struct + Room string + TxHash [32]byte + func GetPostRoom(ctx context.Context, txHash []byte) (*PostRoom, error) + func (r *PostRoom) Deserialize(data []byte) + func (r *PostRoom) GetShardSource() uint + func (r *PostRoom) GetTopic() string + func (r *PostRoom) GetUid() []byte + func (r *PostRoom) Serialize() []byte + func (r *PostRoom) SetUid(uid []byte) + type RoomFollow struct + Addr [25]byte + RoomHash []byte + Seen time.Time + TxHash [32]byte + Unfollow bool + func GetRoomFollows(ctx context.Context, room string) ([]*RoomFollow, error) + func (f *RoomFollow) Deserialize(data []byte) + func (f *RoomFollow) GetShardSource() uint + func (f *RoomFollow) GetTopic() string + func (f *RoomFollow) GetUid() []byte + func (f *RoomFollow) Serialize() []byte + func (f *RoomFollow) SetUid(uid []byte) + type RoomPost struct + RoomHash []byte + Seen time.Time + TxHash [32]byte + func GetRoomPosts(ctx context.Context, room string) ([]*RoomPost, error) + func (p *RoomPost) Deserialize([]byte) + func (p *RoomPost) GetShardSource() uint + func (p *RoomPost) GetTopic() string + func (p *RoomPost) GetUid() []byte + func (p *RoomPost) Serialize() []byte + func (p *RoomPost) SetUid(uid []byte) + type SeenPost struct + PostTxHash [32]byte + Seen time.Time + func GetSeenPosts(ctx context.Context, start time.Time, startTxHash [32]byte, limit uint32) ([]*SeenPost, error) + func (i *SeenPost) Deserialize([]byte) + func (i *SeenPost) GetShardSource() uint + func (i *SeenPost) GetTopic() string + func (i *SeenPost) GetUid() []byte + func (i *SeenPost) Serialize() []byte + func (i *SeenPost) SetUid(uid []byte) v0.2.0-alpha.0 Feb 23, 2023
Go to main page