database

package

Go to main page

Versions in this module

v0

v0.0.12

Jul 24, 2026

v0.0.11

Mar 10, 2026

v0.0.10

Oct 15, 2025

v0.0.9

Oct 6, 2025

v0.0.8

Oct 6, 2025

v0.0.7

May 14, 2025

v0.0.6

May 14, 2025

Changes in this version

type FollowersDatabase

+ func NewNullFollowersDatabase(ctx context.Context, uri string) (FollowersDatabase, error)

type FollowingDatabase

+ func NewNullFollowingDatabase(ctx context.Context, uri string) (FollowingDatabase, error)

type MessagesDatabase

+ func NewNullMessagesDatabase(ctx context.Context, uri string) (MessagesDatabase, error)

type NotesDatabase

+ func NewNullNotesDatabase(ctx context.Context, uri string) (NotesDatabase, error)

+ type NullFollowersDatabase struct

+ func (db *NullFollowersDatabase) Close(ctx context.Context) error

+ func (db *NullFollowersDatabase) GetAllFollowers(ctx context.Context, cb GetFollowersCallbackFunc) error

+ func (db *NullFollowersDatabase) GetFollower(ctx context.Context, account_id int64, follower_address string) (*activitypub.Follower, error)

+ func (db *NullFollowersDatabase) GetFollowerIdsForDateRange(ctx context.Context, start int64, end int64, cb GetFollowerIdsCallbackFunc) error

+ func (db *NullFollowersDatabase) GetFollowerWithId(ctx context.Context, follower_id int64) (*activitypub.Follower, error)

+ func (db *NullFollowersDatabase) HasFollowers(ctx context.Context, account_id int64) (bool, error)

+ type NullFollowingDatabase struct

+ func (db *NullFollowingDatabase) AddFollowing(ctx context.Context, f *activitypub.Following) error

+ func (db *NullFollowingDatabase) Close(ctx context.Context) error

+ func (db *NullFollowingDatabase) GetFollowing(ctx context.Context, account_id int64, following_address string) (*activitypub.Following, error)

+ func (db *NullFollowingDatabase) GetFollowingForAccount(ctx context.Context, account_id int64, ...) error

+ func (db *NullFollowingDatabase) GetFollowingIdsForDateRange(ctx context.Context, start int64, end int64, cb GetFollowingIdsCallbackFunc) error

+ func (db *NullFollowingDatabase) RemoveFollowing(ctx context.Context, f *activitypub.Following) error

+ type NullMessagesDatabase struct

+ func (db *NullMessagesDatabase) AddMessage(ctx context.Context, message *activitypub.Message) error

+ func (db *NullMessagesDatabase) Close(ctx context.Context) error

+ func (db *NullMessagesDatabase) GetMessageIdsForDateRange(ctx context.Context, start int64, end int64, cb GetMessageIdsCallbackFunc) error

+ func (db *NullMessagesDatabase) GetMessageWithAccountAndNoteIds(ctx context.Context, account_id int64, note_id int64) (*activitypub.Message, error)

+ func (db *NullMessagesDatabase) GetMessageWithId(ctx context.Context, message_id int64) (*activitypub.Message, error)

+ func (db *NullMessagesDatabase) GetMessagesForAccount(ctx context.Context, account_id int64, callback_func GetMessagesCallbackFunc) error

+ func (db *NullMessagesDatabase) GetMessagesForAccountAndAuthor(ctx context.Context, account_id int64, author_address string, ...) error

+ func (db *NullMessagesDatabase) RemoveMessage(ctx context.Context, message *activitypub.Message) error

+ func (db *NullMessagesDatabase) UpdateMessage(ctx context.Context, message *activitypub.Message) error

+ type NullNotesDatabase struct

+ func (db *NullNotesDatabase) AddNote(ctx context.Context, note *activitypub.Note) error

+ func (db *NullNotesDatabase) Close(ctx context.Context) error

+ func (db *NullNotesDatabase) GetNoteIdsForDateRange(ctx context.Context, start int64, end int64, cb GetNoteIdsCallbackFunc) error

+ func (db *NullNotesDatabase) GetNoteWithId(ctx context.Context, note_id int64) (*activitypub.Note, error)

+ func (db *NullNotesDatabase) GetNoteWithUUIDAndAuthorAddress(ctx context.Context, note_uuid string, author_address string) (*activitypub.Note, error)

+ func (db *NullNotesDatabase) RemoveNote(ctx context.Context, note *activitypub.Note) error

+ func (db *NullNotesDatabase) UpdateNote(ctx context.Context, note *activitypub.Note) error

+ type NullPostsDatabase struct

+ func (db *NullPostsDatabase) AddPost(ctx context.Context, p *activitypub.Post) error

+ func (db *NullPostsDatabase) Close(ctx context.Context) error

+ func (db *NullPostsDatabase) GetPostIdsForDateRange(ctx context.Context, start int64, end int64, cb GetPostIdsCallbackFunc) error

+ func (db *NullPostsDatabase) GetPostWithId(ctx context.Context, id int64) (*activitypub.Post, error)

+ func (db *NullPostsDatabase) UpdatePost(ctx context.Context, p *activitypub.Post) error

type PostsDatabase

+ func NewNullPostsDatabase(ctx context.Context, uri string) (PostsDatabase, error)

v0.0.5

May 13, 2025

v0.0.4

Apr 15, 2025

v0.0.3

Nov 25, 2024

Changes in this version

type DocstoreFollowersDatabase

+ func (db *DocstoreFollowersDatabase) GetFollowerWithId(ctx context.Context, follower_id int64) (*activitypub.Follower, error)

type FollowersDatabase

+ GetFollowerWithId func(context.Context, int64) (*activitypub.Follower, error)

type SQLFollowersDatabase

+ func (db *SQLFollowersDatabase) GetFollowerWithId(ctx context.Context, follower_id int64) (*activitypub.Follower, error)

v0.0.2

Nov 12, 2024

Changes in this version

+ const SQL_ACCOUNTS_TABLE_NAME

+ const SQL_ACTIVITIES_TABLE_NAME

+ const SQL_ALIASES_TABLE_NAME

+ const SQL_BLOCKS_TABLE_NAME

+ const SQL_BOOSTS_TABLE_NAME

+ const SQL_DELIVERIES_TABLE_NAME

+ const SQL_FOLLOWERS_TABLE_NAME

+ const SQL_FOLLOWING_TABLE_NAME

+ const SQL_LIKES_TABLE_NAME

+ const SQL_MESSAGES_TABLE_NAME

+ const SQL_NOTES_TABLE_NAME

+ const SQL_POSTS_TABLE_NAME

+ const SQL_POST_TAGS_TABLE_NAME

+ const SQL_PROPERTIES_TABLE_NAME

+ func AccountsDatabaseSchemes() []string

+ func ActivitiesDatabaseSchemes() []string

+ func AliasesDatabaseSchemes() []string

+ func BlocksDatabaseSchemes() []string

+ func BoostsDatabaseSchemes() []string

+ func DeliveriesDatabaseSchemes() []string

+ func FollowersDatabaseSchemes() []string

+ func FollowingDatabaseSchemes() []string

+ func LikesDatabaseSchemes() []string

+ func MessagesDatabaseSchemes() []string

+ func NotesDatabaseSchemes() []string

+ func PostTagsDatabaseSchemes() []string

+ func PostsDatabaseSchemes() []string

+ func PropertiesDatabaseSchemes() []string

+ func RegisterAccountsDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterActivitiesDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterAliasesDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterBlocksDatabase(ctx context.Context, scheme string, init_func BlocksDatabaseInitializationFunc) error

+ func RegisterBoostsDatabase(ctx context.Context, scheme string, init_func BoostsDatabaseInitializationFunc) error

+ func RegisterDeliveriesDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterFollowersDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterFollowingDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterLikesDatabase(ctx context.Context, scheme string, init_func LikesDatabaseInitializationFunc) error

+ func RegisterMessagesDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterNotesDatabase(ctx context.Context, scheme string, init_func NotesDatabaseInitializationFunc) error

+ func RegisterPostTagsDatabase(ctx context.Context, scheme string, ...) error

+ func RegisterPostsDatabase(ctx context.Context, scheme string, init_func PostsDatabaseInitializationFunc) error

+ func RegisterPropertiesDatabase(ctx context.Context, scheme string, ...) error

+ type AccountsDatabase interface

+ AddAccount func(context.Context, *activitypub.Account) error

+ Close func(context.Context) error

+ GetAccountIdsForDateRange func(context.Context, int64, int64, GetAccountIdsCallbackFunc) error

+ GetAccountWithId func(context.Context, int64) (*activitypub.Account, error)

+ GetAccountWithName func(context.Context, string) (*activitypub.Account, error)

+ GetAccounts func(context.Context, GetAccountsCallbackFunc) error

+ RemoveAccount func(context.Context, *activitypub.Account) error

+ UpdateAccount func(context.Context, *activitypub.Account) error

+ func NewAccountsDatabase(ctx context.Context, uri string) (AccountsDatabase, error)

+ func NewDocstoreAccountsDatabase(ctx context.Context, uri string) (AccountsDatabase, error)

+ func NewNullAccountsDatabase(ctx context.Context, uri string) (AccountsDatabase, error)

+ func NewSQLAccountsDatabase(ctx context.Context, uri string) (AccountsDatabase, error)

+ type AccountsDatabaseInitializationFunc func(ctx context.Context, uri string) (AccountsDatabase, error)

+ type ActivitiesDatabase interface

+ AddActivity func(context.Context, *activitypub.Activity) error

+ Close func(context.Context) error

+ GetActivities func(context.Context, GetActivitiesCallbackFunc) error

+ GetActivitiesForAccount func(context.Context, int64, GetActivitiesCallbackFunc) error

+ GetActivityWithActivityPubId func(context.Context, string) (*activitypub.Activity, error)

+ GetActivityWithActivityTypeAnId func(context.Context, activitypub.ActivityType, int64) (*activitypub.Activity, error)

+ GetActivityWithId func(context.Context, int64) (*activitypub.Activity, error)

+ func NewActivitiesDatabase(ctx context.Context, uri string) (ActivitiesDatabase, error)

+ func NewDocstoreActivitiesDatabase(ctx context.Context, uri string) (ActivitiesDatabase, error)

+ func NewNullActivitiesDatabase(ctx context.Context, uri string) (ActivitiesDatabase, error)

+ func NewSQLActivitiesDatabase(ctx context.Context, uri string) (ActivitiesDatabase, error)

+ type ActivitiesDatabaseInitializationFunc func(ctx context.Context, uri string) (ActivitiesDatabase, error)

+ type AliasesDatabase interface

+ AddAlias func(context.Context, *activitypub.Alias) error

+ Close func(context.Context) error

+ GetAliasWithName func(context.Context, string) (*activitypub.Alias, error)

+ GetAliasesForAccount func(context.Context, int64, GetAliasesCallbackFunc) error

+ RemoveAlias func(context.Context, *activitypub.Alias) error

+ func NewAliasesDatabase(ctx context.Context, uri string) (AliasesDatabase, error)

+ func NewDocstoreAliasesDatabase(ctx context.Context, uri string) (AliasesDatabase, error)

+ func NewNullAliasesDatabase(ctx context.Context, uri string) (AliasesDatabase, error)

+ func NewSQLAliasesDatabase(ctx context.Context, uri string) (AliasesDatabase, error)

+ type AliasesDatabaseInitializationFunc func(ctx context.Context, uri string) (AliasesDatabase, error)

+ type BlocksDatabase interface

+ AddBlock func(context.Context, *activitypub.Block) error

+ Close func(context.Context) error

+ GetBlockIdsForDateRange func(context.Context, int64, int64, GetBlockIdsCallbackFunc) error

+ GetBlockWithAccountIdAndAddress func(context.Context, int64, string, string) (*activitypub.Block, error)

+ GetBlockWithId func(context.Context, int64) (*activitypub.Block, error)

+ RemoveBlock func(context.Context, *activitypub.Block) error

+ func NewBlocksDatabase(ctx context.Context, uri string) (BlocksDatabase, error)

+ func NewDocstoreBlocksDatabase(ctx context.Context, uri string) (BlocksDatabase, error)

+ func NewNullBlocksDatabase(ctx context.Context, uri string) (BlocksDatabase, error)

+ func NewSQLBlocksDatabase(ctx context.Context, uri string) (BlocksDatabase, error)

+ type BlocksDatabaseInitializationFunc func(ctx context.Context, uri string) (BlocksDatabase, error)

+ type BoostsDatabase interface

+ AddBoost func(context.Context, *activitypub.Boost) error

+ Close func(context.Context) error

+ GetBoostIdsForDateRange func(context.Context, int64, int64, GetBoostIdsCallbackFunc) error

+ GetBoostWithId func(context.Context, int64) (*activitypub.Boost, error)

+ GetBoostWithPostIdAndActor func(context.Context, int64, string) (*activitypub.Boost, error)

+ GetBoostsForAccount func(context.Context, int64, GetBoostsCallbackFunc) error

+ GetBoostsForPost func(context.Context, int64, GetBoostsCallbackFunc) error

+ RemoveBoost func(context.Context, *activitypub.Boost) error

+ func NewBoostsDatabase(ctx context.Context, uri string) (BoostsDatabase, error)

+ func NewDocstoreBoostsDatabase(ctx context.Context, uri string) (BoostsDatabase, error)

+ func NewNullBoostsDatabase(ctx context.Context, uri string) (BoostsDatabase, error)

+ func NewSQLBoostsDatabase(ctx context.Context, uri string) (BoostsDatabase, error)

+ type BoostsDatabaseInitializationFunc func(ctx context.Context, uri string) (BoostsDatabase, error)

+ type DeliveriesDatabase interface

+ AddDelivery func(context.Context, *activitypub.Delivery) error

+ Close func(context.Context) error

+ GetDeliveries func(context.Context, GetDeliveriesCallbackFunc) error

+ GetDeliveriesWithActivityIdAndRecipient func(context.Context, int64, string, GetDeliveriesCallbackFunc) error

+ GetDeliveriesWithActivityPubIdAndRecipient func(context.Context, string, string, GetDeliveriesCallbackFunc) error

+ GetDeliveryIdsForDateRange func(context.Context, int64, int64, GetDeliveryIdsCallbackFunc) error

+ GetDeliveryWithId func(context.Context, int64) (*activitypub.Delivery, error)

+ func NewDeliveriesDatabase(ctx context.Context, uri string) (DeliveriesDatabase, error)

+ func NewDocstoreDeliveriesDatabase(ctx context.Context, uri string) (DeliveriesDatabase, error)

+ func NewNullDeliveriesDatabase(ctx context.Context, uri string) (DeliveriesDatabase, error)

+ func NewSQLDeliveriesDatabase(ctx context.Context, uri string) (DeliveriesDatabase, error)

+ func NewSlogDeliveriesDatabase(ctx context.Context, uri string) (DeliveriesDatabase, error)

+ type DeliveriesDatabaseInitializationFunc func(ctx context.Context, uri string) (DeliveriesDatabase, error)

+ type DocstoreAccountsDatabase struct

+ func (db *DocstoreAccountsDatabase) AddAccount(ctx context.Context, a *activitypub.Account) error

+ func (db *DocstoreAccountsDatabase) Close(ctx context.Context) error

+ func (db *DocstoreAccountsDatabase) GetAccountIdsForDateRange(ctx context.Context, start int64, end int64, cb GetAccountIdsCallbackFunc) error

+ func (db *DocstoreAccountsDatabase) GetAccountWithId(ctx context.Context, id int64) (*activitypub.Account, error)

+ func (db *DocstoreAccountsDatabase) GetAccountWithName(ctx context.Context, name string) (*activitypub.Account, error)

+ func (db *DocstoreAccountsDatabase) GetAccounts(ctx context.Context, cb GetAccountsCallbackFunc) error

+ func (db *DocstoreAccountsDatabase) RemoveAccount(ctx context.Context, acct *activitypub.Account) error

+ func (db *DocstoreAccountsDatabase) UpdateAccount(ctx context.Context, acct *activitypub.Account) error

+ type DocstoreActivitiesDatabase struct

+ func (db *DocstoreActivitiesDatabase) AddActivity(ctx context.Context, f *activitypub.Activity) error

+ func (db *DocstoreActivitiesDatabase) Close(ctx context.Context) error

+ func (db *DocstoreActivitiesDatabase) GetActivities(ctx context.Context, cb GetActivitiesCallbackFunc) error

+ func (db *DocstoreActivitiesDatabase) GetActivitiesForAccount(ctx context.Context, id int64, cb GetActivitiesCallbackFunc) error

+ func (db *DocstoreActivitiesDatabase) GetActivityWithActivityPubId(ctx context.Context, id string) (*activitypub.Activity, error)

+ func (db *DocstoreActivitiesDatabase) GetActivityWithActivityTypeAndId(ctx context.Context, activity_type activitypub.ActivityType, id int64) (*activitypub.Activity, error)

+ func (db *DocstoreActivitiesDatabase) GetActivityWithId(ctx context.Context, id int64) (*activitypub.Activity, error)

+ type DocstoreAliasesDatabase struct

+ func (db *DocstoreAliasesDatabase) AddAlias(ctx context.Context, alias *activitypub.Alias) error

+ func (db *DocstoreAliasesDatabase) Close(ctx context.Context) error

+ func (db *DocstoreAliasesDatabase) GetAliasWithName(ctx context.Context, name string) (*activitypub.Alias, error)

+ func (db *DocstoreAliasesDatabase) GetAliasesForAccount(ctx context.Context, account_id int64, cb GetAliasesCallbackFunc) error

+ func (db *DocstoreAliasesDatabase) RemoveAlias(ctx context.Context, alias *activitypub.Alias) error

+ type DocstoreBlocksDatabase struct

+ func (db *DocstoreBlocksDatabase) AddBlock(ctx context.Context, block *activitypub.Block) error

+ func (db *DocstoreBlocksDatabase) Close(ctx context.Context) error

+ func (db *DocstoreBlocksDatabase) GetBlockIdsForDateRange(ctx context.Context, start int64, end int64, cb GetBlockIdsCallbackFunc) error

+ func (db *DocstoreBlocksDatabase) GetBlockWithAccountIdAndAddress(ctx context.Context, account_id int64, host string, name string) (*activitypub.Block, error)

+ func (db *DocstoreBlocksDatabase) GetBlockWithId(ctx context.Context, id int64) (*activitypub.Block, error)

+ func (db *DocstoreBlocksDatabase) RemoveBlock(ctx context.Context, block *activitypub.Block) error

+ func (db *DocstoreBlocksDatabase) UpdateBlock(ctx context.Context, block *activitypub.Block) error

+ type DocstoreBoostsDatabase struct

+ func (db *DocstoreBoostsDatabase) AddBoost(ctx context.Context, boost *activitypub.Boost) error

+ func (db *DocstoreBoostsDatabase) Close(ctx context.Context) error

+ func (db *DocstoreBoostsDatabase) GetBoostIdsForDateRange(ctx context.Context, start int64, end int64, cb GetBoostIdsCallbackFunc) error

+ func (db *DocstoreBoostsDatabase) GetBoostWithId(ctx context.Context, id int64) (*activitypub.Boost, error)

+ func (db *DocstoreBoostsDatabase) GetBoostWithPostIdAndActor(ctx context.Context, post_id int64, actor string) (*activitypub.Boost, error)

+ func (db *DocstoreBoostsDatabase) GetBoostsForAccount(ctx context.Context, account_id int64, cb GetBoostsCallbackFunc) error

+ func (db *DocstoreBoostsDatabase) GetBoostsForPost(ctx context.Context, post_id int64, cb GetBoostsCallbackFunc) error

+ func (db *DocstoreBoostsDatabase) RemoveBoost(ctx context.Context, boost *activitypub.Boost) error

+ type DocstoreDeliveriesDatabase struct

+ func (db *DocstoreDeliveriesDatabase) AddDelivery(ctx context.Context, f *activitypub.Delivery) error

+ func (db *DocstoreDeliveriesDatabase) Close(ctx context.Context) error

+ func (db *DocstoreDeliveriesDatabase) GetDeliveries(ctx context.Context, deliveries_callback GetDeliveriesCallbackFunc) error

+ func (db *DocstoreDeliveriesDatabase) GetDeliveriesWithActivityIdAndRecipient(ctx context.Context, activity_id int64, recipient string, ...) error

+ func (db *DocstoreDeliveriesDatabase) GetDeliveriesWithActivityPubIdAndRecipient(ctx context.Context, activity_pub_id string, recipient string, ...) error

+ func (db *DocstoreDeliveriesDatabase) GetDeliveryIdsForDateRange(ctx context.Context, start int64, end int64, cb GetDeliveryIdsCallbackFunc) error

+ func (db *DocstoreDeliveriesDatabase) GetDeliveryWithId(ctx context.Context, id int64) (*activitypub.Delivery, error)

+ type DocstoreFollowersDatabase struct

+ func (db *DocstoreFollowersDatabase) AddFollower(ctx context.Context, f *activitypub.Follower) error

+ func (db *DocstoreFollowersDatabase) Close(ctx context.Context) error

+ func (db *DocstoreFollowersDatabase) GetAllFollowers(ctx context.Context, cb GetFollowersCallbackFunc) error

+ func (db *DocstoreFollowersDatabase) GetFollower(ctx context.Context, account_id int64, follower_address string) (*activitypub.Follower, error)

+ func (db *DocstoreFollowersDatabase) GetFollowerIdsForDateRange(ctx context.Context, start int64, end int64, cb GetFollowerIdsCallbackFunc) error

+ func (db *DocstoreFollowersDatabase) GetFollowersForAccount(ctx context.Context, account_id int64, cb GetFollowersCallbackFunc) error

+ func (db *DocstoreFollowersDatabase) HasFollowers(ctx context.Context, account_id int64) (bool, error)

+ func (db *DocstoreFollowersDatabase) RemoveFollower(ctx context.Context, f *activitypub.Follower) error

+ type DocstoreFollowingDatabase struct

+ func (db *DocstoreFollowingDatabase) AddFollowing(ctx context.Context, f *activitypub.Following) error

+ func (db *DocstoreFollowingDatabase) Close(ctx context.Context) error

+ func (db *DocstoreFollowingDatabase) GetFollowing(ctx context.Context, account_id int64, following_address string) (*activitypub.Following, error)

+ func (db *DocstoreFollowingDatabase) GetFollowingForAccount(ctx context.Context, account_id int64, ...) error

+ func (db *DocstoreFollowingDatabase) GetFollowingIdsForDateRange(ctx context.Context, start int64, end int64, cb GetFollowingIdsCallbackFunc) error

+ func (db *DocstoreFollowingDatabase) RemoveFollowing(ctx context.Context, f *activitypub.Following) error

+ type DocstoreLikesDatabase struct

+ func (db *DocstoreLikesDatabase) AddLike(ctx context.Context, like *activitypub.Like) error

+ func (db *DocstoreLikesDatabase) Close(ctx context.Context) error

+ func (db *DocstoreLikesDatabase) GetLikeIdsForDateRange(ctx context.Context, start int64, end int64, cb GetLikeIdsCallbackFunc) error

+ func (db *DocstoreLikesDatabase) GetLikeWithId(ctx context.Context, id int64) (*activitypub.Like, error)

+ func (db *DocstoreLikesDatabase) GetLikeWithPostIdAndActor(ctx context.Context, post_id int64, actor string) (*activitypub.Like, error)

+ func (db *DocstoreLikesDatabase) GetLikesForPost(ctx context.Context, post_id int64, cb GetLikesCallbackFunc) error

+ func (db *DocstoreLikesDatabase) RemoveLike(ctx context.Context, like *activitypub.Like) error

+ type DocstoreMessagesDatabase struct

+ func (db *DocstoreMessagesDatabase) AddMessage(ctx context.Context, message *activitypub.Message) error

+ func (db *DocstoreMessagesDatabase) Close(ctx context.Context) error

+ func (db *DocstoreMessagesDatabase) GetMessageIdsForDateRange(ctx context.Context, start int64, end int64, cb GetMessageIdsCallbackFunc) error

+ func (db *DocstoreMessagesDatabase) GetMessageWithAccountAndNoteIds(ctx context.Context, account_id int64, note_id int64) (*activitypub.Message, error)

+ func (db *DocstoreMessagesDatabase) GetMessageWithId(ctx context.Context, message_id int64) (*activitypub.Message, error)

+ func (db *DocstoreMessagesDatabase) GetMessagesForAccount(ctx context.Context, account_id int64, callback_func GetMessagesCallbackFunc) error

+ func (db *DocstoreMessagesDatabase) GetMessagesForAccountAndAuthor(ctx context.Context, account_id int64, author_address string, ...) error

+ func (db *DocstoreMessagesDatabase) RemoveMessage(ctx context.Context, message *activitypub.Message) error

+ func (db *DocstoreMessagesDatabase) UpdateMessage(ctx context.Context, message *activitypub.Message) error

+ type DocstoreNotesDatabase struct

+ func (db *DocstoreNotesDatabase) AddNote(ctx context.Context, note *activitypub.Note) error

+ func (db *DocstoreNotesDatabase) Close(ctx context.Context) error

+ func (db *DocstoreNotesDatabase) GetNoteIdsForDateRange(ctx context.Context, start int64, end int64, cb GetNoteIdsCallbackFunc) error

+ func (db *DocstoreNotesDatabase) GetNoteWithId(ctx context.Context, note_id int64) (*activitypub.Note, error)

+ func (db *DocstoreNotesDatabase) GetNoteWithUUIDAndAuthorAddress(ctx context.Context, note_uuid string, author_address string) (*activitypub.Note, error)

+ func (db *DocstoreNotesDatabase) RemoveNote(ctx context.Context, note *activitypub.Note) error

+ func (db *DocstoreNotesDatabase) UpdateNote(ctx context.Context, note *activitypub.Note) error

+ type DocstorePostTagsDatabase struct

+ func (db *DocstorePostTagsDatabase) AddPostTag(ctx context.Context, tag *activitypub.PostTag) error

+ func (db *DocstorePostTagsDatabase) Close(ctx context.Context) error

+ func (db *DocstorePostTagsDatabase) GetPostTagIdsForDateRange(ctx context.Context, start int64, end int64, cb GetPostTagIdsCallbackFunc) error

+ func (db *DocstorePostTagsDatabase) GetPostTagWithId(ctx context.Context, id int64) (*activitypub.PostTag, error)

+ func (db *DocstorePostTagsDatabase) GetPostTagsForAccount(ctx context.Context, account_id int64, cb GetPostTagsCallbackFunc) error

+ func (db *DocstorePostTagsDatabase) GetPostTagsForName(ctx context.Context, name string, cb GetPostTagsCallbackFunc) error

+ func (db *DocstorePostTagsDatabase) GetPostTagsForPost(ctx context.Context, post_id int64, cb GetPostTagsCallbackFunc) error

+ func (db *DocstorePostTagsDatabase) RemovePostTag(ctx context.Context, tag *activitypub.PostTag) error

+ type DocstorePostsDatabase struct

+ func (db *DocstorePostsDatabase) AddPost(ctx context.Context, p *activitypub.Post) error

+ func (db *DocstorePostsDatabase) Close(ctx context.Context) error

+ func (db *DocstorePostsDatabase) GetPostIdsForDateRange(ctx context.Context, start int64, end int64, cb GetPostIdsCallbackFunc) error

+ func (db *DocstorePostsDatabase) GetPostWithId(ctx context.Context, id int64) (*activitypub.Post, error)

+ func (db *DocstorePostsDatabase) UpdatePost(ctx context.Context, p *activitypub.Post) error

+ type DocstorePropertiesDatabase struct

+ func (db *DocstorePropertiesDatabase) AddProperty(ctx context.Context, property *activitypub.Property) error

+ func (db *DocstorePropertiesDatabase) Close(ctx context.Context) error

+ func (db *DocstorePropertiesDatabase) GetProperties(ctx context.Context, cb GetPropertiesCallbackFunc) error

+ func (db *DocstorePropertiesDatabase) GetPropertiesForAccount(ctx context.Context, account_id int64, cb GetPropertiesCallbackFunc) error

+ func (db *DocstorePropertiesDatabase) RemoveProperty(ctx context.Context, property *activitypub.Property) error

+ func (db *DocstorePropertiesDatabase) UpdateProperty(ctx context.Context, property *activitypub.Property) error

+ type FollowersDatabase interface

+ AddFollower func(context.Context, *activitypub.Follower) error

+ Close func(context.Context) error

+ GetAllFollowers func(context.Context, GetFollowersCallbackFunc) error

+ GetFollower func(context.Context, int64, string) (*activitypub.Follower, error)

+ GetFollowerIdsForDateRange func(context.Context, int64, int64, GetFollowerIdsCallbackFunc) error

+ GetFollowersForAccount func(context.Context, int64, GetFollowersCallbackFunc) error

+ HasFollowers func(context.Context, int64) (bool, error)

+ RemoveFollower func(context.Context, *activitypub.Follower) error

+ func NewDocstoreFollowersDatabase(ctx context.Context, uri string) (FollowersDatabase, error)

+ func NewFollowersDatabase(ctx context.Context, uri string) (FollowersDatabase, error)

+ func NewSQLFollowersDatabase(ctx context.Context, uri string) (FollowersDatabase, error)

+ type FollowersDatabaseInitializationFunc func(ctx context.Context, uri string) (FollowersDatabase, error)

+ type FollowingDatabase interface

+ AddFollowing func(context.Context, *activitypub.Following) error

+ Close func(context.Context) error

+ GetFollowing func(context.Context, int64, string) (*activitypub.Following, error)

+ GetFollowingForAccount func(context.Context, int64, GetFollowingCallbackFunc) error

+ GetFollowingIdsForDateRange func(context.Context, int64, int64, GetFollowingIdsCallbackFunc) error

+ RemoveFollowing func(context.Context, *activitypub.Following) error

+ func NewDocstoreFollowingDatabase(ctx context.Context, uri string) (FollowingDatabase, error)

+ func NewFollowingDatabase(ctx context.Context, uri string) (FollowingDatabase, error)

+ func NewSQLFollowingDatabase(ctx context.Context, uri string) (FollowingDatabase, error)

+ type FollowingDatabaseInitializationFunc func(ctx context.Context, uri string) (FollowingDatabase, error)

+ type GetAccountIdsCallbackFunc func(context.Context, int64) error

+ type GetAccountsCallbackFunc func(context.Context, *activitypub.Account) error

+ type GetActivitiesCallbackFunc func(context.Context, *activitypub.Activity) error

+ type GetAliasesCallbackFunc func(context.Context, *activitypub.Alias) error

+ type GetBlockIdsCallbackFunc func(context.Context, int64) error

+ type GetBlocksCallbackFunc func(context.Context, *activitypub.Block) error

+ type GetBoostIdsCallbackFunc func(context.Context, int64) error

+ type GetBoostsCallbackFunc func(context.Context, *activitypub.Boost) error

+ type GetDeliveriesCallbackFunc func(context.Context, *activitypub.Delivery) error

+ type GetDeliveryIdsCallbackFunc func(context.Context, int64) error

+ type GetFollowerIdsCallbackFunc func(context.Context, int64) error

+ type GetFollowersCallbackFunc func(context.Context, string) error

+ type GetFollowingCallbackFunc func(context.Context, string) error

+ type GetFollowingIdsCallbackFunc func(context.Context, int64) error

+ type GetLikeIdsCallbackFunc func(context.Context, int64) error

+ type GetLikesCallbackFunc func(context.Context, *activitypub.Like) error

+ type GetMessageIdsCallbackFunc func(context.Context, int64) error

+ type GetMessagesCallbackFunc func(context.Context, *activitypub.Message) error

+ type GetNoteIdsCallbackFunc func(context.Context, int64) error

+ type GetNotesCallbackFunc func(context.Context, *activitypub.Note) error

+ type GetPostIdsCallbackFunc func(context.Context, int64) error

+ type GetPostTagIdsCallbackFunc func(context.Context, int64) error

+ type GetPostTagsCallbackFunc func(context.Context, *activitypub.PostTag) error

+ type GetPropertiesCallbackFunc func(context.Context, *activitypub.Property) error

+ type LikesDatabase interface

+ AddLike func(context.Context, *activitypub.Like) error

+ Close func(context.Context) error

+ GetLikeIdsForDateRange func(context.Context, int64, int64, GetLikeIdsCallbackFunc) error

+ GetLikeWithId func(context.Context, int64) (*activitypub.Like, error)

+ GetLikeWithPostIdAndActor func(context.Context, int64, string) (*activitypub.Like, error)

+ GetLikesForPost func(context.Context, int64, GetLikesCallbackFunc) error

+ RemoveLike func(context.Context, *activitypub.Like) error

+ func NewDocstoreLikesDatabase(ctx context.Context, uri string) (LikesDatabase, error)

+ func NewLikesDatabase(ctx context.Context, uri string) (LikesDatabase, error)

+ func NewNullLikesDatabase(ctx context.Context, uri string) (LikesDatabase, error)

+ func NewSQLLikesDatabase(ctx context.Context, uri string) (LikesDatabase, error)

+ type LikesDatabaseInitializationFunc func(ctx context.Context, uri string) (LikesDatabase, error)

+ type MessagesDatabase interface

+ AddMessage func(context.Context, *activitypub.Message) error

+ Close func(context.Context) error

+ GetMessageIdsForDateRange func(context.Context, int64, int64, GetMessageIdsCallbackFunc) error

+ GetMessageWithAccountAndNoteIds func(context.Context, int64, int64) (*activitypub.Message, error)

+ GetMessageWithId func(context.Context, int64) (*activitypub.Message, error)

+ GetMessagesForAccount func(context.Context, int64, GetMessagesCallbackFunc) error

+ GetMessagesForAccountAndAuthor func(context.Context, int64, string, GetMessagesCallbackFunc) error

+ RemoveMessage func(context.Context, *activitypub.Message) error

+ UpdateMessage func(context.Context, *activitypub.Message) error

+ func NewDocstoreMessagesDatabase(ctx context.Context, uri string) (MessagesDatabase, error)

+ func NewMessagesDatabase(ctx context.Context, uri string) (MessagesDatabase, error)

+ func NewSQLMessagesDatabase(ctx context.Context, uri string) (MessagesDatabase, error)

+ type MessagesDatabaseInitializationFunc func(ctx context.Context, uri string) (MessagesDatabase, error)

+ type NotesDatabase interface

+ AddNote func(context.Context, *activitypub.Note) error

+ Close func(context.Context) error

+ GetNoteIdsForDateRange func(context.Context, int64, int64, GetNoteIdsCallbackFunc) error

+ GetNoteWithId func(context.Context, int64) (*activitypub.Note, error)

+ GetNoteWithUUIDAndAuthorAddress func(context.Context, string, string) (*activitypub.Note, error)

+ RemoveNote func(context.Context, *activitypub.Note) error

+ UpdateNote func(context.Context, *activitypub.Note) error

+ func NewDocstoreNotesDatabase(ctx context.Context, uri string) (NotesDatabase, error)

+ func NewNotesDatabase(ctx context.Context, uri string) (NotesDatabase, error)

+ func NewSQLNotesDatabase(ctx context.Context, uri string) (NotesDatabase, error)

+ type NotesDatabaseInitializationFunc func(ctx context.Context, uri string) (NotesDatabase, error)

+ type NullAccountsDatabase struct

+ func (db *NullAccountsDatabase) AddAccount(ctx context.Context, a *activitypub.Account) error

+ func (db *NullAccountsDatabase) Close(ctx context.Context) error

+ func (db *NullAccountsDatabase) GetAccountIdsForDateRange(ctx context.Context, start int64, end int64, cb GetAccountIdsCallbackFunc) error

+ func (db *NullAccountsDatabase) GetAccountWithId(ctx context.Context, id int64) (*activitypub.Account, error)

+ func (db *NullAccountsDatabase) GetAccountWithName(ctx context.Context, name string) (*activitypub.Account, error)

+ func (db *NullAccountsDatabase) GetAccounts(ctx context.Context, cb GetAccountsCallbackFunc) error

+ func (db *NullAccountsDatabase) RemoveAccount(ctx context.Context, acct *activitypub.Account) error

+ func (db *NullAccountsDatabase) UpdateAccount(ctx context.Context, acct *activitypub.Account) error

+ type NullActivitiesDatabase struct

+ func (db *NullActivitiesDatabase) AddActivity(ctx context.Context, f *activitypub.Activity) error

+ func (db *NullActivitiesDatabase) Close(ctx context.Context) error

+ func (db *NullActivitiesDatabase) GetActivities(ctx context.Context, cb GetActivitiesCallbackFunc) error

+ func (db *NullActivitiesDatabase) GetActivitiesForAccount(ctx context.Context, id int64, cb GetActivitiesCallbackFunc) error

+ func (db *NullActivitiesDatabase) GetActivityWithActivityPubId(ctx context.Context, id string) (*activitypub.Activity, error)

+ func (db *NullActivitiesDatabase) GetActivityWithActivityTypeAndId(ctx context.Context, activity_type activitypub.ActivityType, id int64) (*activitypub.Activity, error)

+ func (db *NullActivitiesDatabase) GetActivityWithId(ctx context.Context, id int64) (*activitypub.Activity, error)

+ type NullAliasesDatabase struct

+ func (db *NullAliasesDatabase) AddAlias(ctx context.Context, alias *activitypub.Alias) error

+ func (db *NullAliasesDatabase) Close(ctx context.Context) error

+ func (db *NullAliasesDatabase) GetAliasWithName(ctx context.Context, name string) (*activitypub.Alias, error)

+ func (db *NullAliasesDatabase) GetAliasesForAccount(ctx context.Context, account_id int64, cb GetAliasesCallbackFunc) error

+ func (db *NullAliasesDatabase) RemoveAlias(ctx context.Context, alias *activitypub.Alias) error

+ type NullBlocksDatabase struct

+ func (db *NullBlocksDatabase) AddBlock(ctx context.Context, block *activitypub.Block) error

+ func (db *NullBlocksDatabase) GetBlockIdsForDateRange(ctx context.Context, start int64, end int64, cb GetBlockIdsCallbackFunc) error

+ func (db *NullBlocksDatabase) GetBlockWithAccountIdAndAddress(ctx context.Context, account_id int64, host string, name string) (*activitypub.Block, error)

+ func (db *NullBlocksDatabase) GetBlockWithId(ctx context.Context, block_id int64) (*activitypub.Block, error)

+ func (db *NullBlocksDatabase) IsBlockedByAccount(ctx context.Context, account_id int64, host string, name string) (bool, error)

+ func (db *NullBlocksDatabase) RemoveBlock(ctx context.Context, block *activitypub.Block) error

+ func (db *NullBlocksDatabase) UpdateBlock(ctx context.Context, block *activitypub.Block) error

+ type NullBoostsDatabase struct

+ func (db *NullBoostsDatabase) AddBoost(ctx context.Context, boost *activitypub.Boost) error

+ func (db *NullBoostsDatabase) Close(ctx context.Context) error

+ func (db *NullBoostsDatabase) GetBoostIdsForDateRange(ctx context.Context, start int64, end int64, cb GetBoostIdsCallbackFunc) error

+ func (db *NullBoostsDatabase) GetBoostWithId(ctx context.Context, id int64) (*activitypub.Boost, error)

+ func (db *NullBoostsDatabase) GetBoostWithPostIdAndActor(ctx context.Context, id int64, actor string) (*activitypub.Boost, error)

+ func (db *NullBoostsDatabase) GetBoostsForAccount(ctx context.Context, account_id int64, cb GetBoostsCallbackFunc) error

+ func (db *NullBoostsDatabase) GetBoostsForPost(ctx context.Context, post_id int64, cb GetBoostsCallbackFunc) error

+ func (db *NullBoostsDatabase) RemoveBoost(ctx context.Context, boost *activitypub.Boost) error

+ type NullDeliveriesDatabase struct

+ func (db *NullDeliveriesDatabase) AddDelivery(ctx context.Context, d *activitypub.Delivery) error

+ func (db *NullDeliveriesDatabase) Close(ctx context.Context) error

+ func (db *NullDeliveriesDatabase) GetDeliveries(ctx context.Context, cb GetDeliveriesCallbackFunc) error

+ func (db *NullDeliveriesDatabase) GetDeliveriesWithActivityIdAndRecipient(ctx context.Context, activity_id int64, recipient string, ...) error

+ func (db *NullDeliveriesDatabase) GetDeliveriesWithActivityPubIdAndRecipient(ctx context.Context, activity_pub_id string, recipient string, ...) error

+ func (db *NullDeliveriesDatabase) GetDeliveryIdsForDateRange(ctx context.Context, start int64, end int64, cb GetDeliveryIdsCallbackFunc) error

+ func (db *NullDeliveriesDatabase) GetDeliveryWithId(ctx context.Context, id int64) (*activitypub.Delivery, error)

+ type NullLikesDatabase struct

+ func (db *NullLikesDatabase) AddLike(ctx context.Context, like *activitypub.Like) error

+ func (db *NullLikesDatabase) Close(ctx context.Context) error

+ func (db *NullLikesDatabase) GetLikeIdsForDateRange(ctx context.Context, start int64, end int64, cb GetLikeIdsCallbackFunc) error

+ func (db *NullLikesDatabase) GetLikeWithId(ctx context.Context, id int64) (*activitypub.Like, error)

+ func (db *NullLikesDatabase) GetLikeWithPostIdAndActor(ctx context.Context, id int64, actor string) (*activitypub.Like, error)

+ func (db *NullLikesDatabase) GetLikesForPost(ctx context.Context, post_id int64, cb GetLikesCallbackFunc) error

+ func (db *NullLikesDatabase) RemoveLike(ctx context.Context, like *activitypub.Like) error

+ type NullPostTagsDatabase struct

+ func (db *NullPostTagsDatabase) AddPostTag(ctx context.Context, boost *activitypub.PostTag) error

+ func (db *NullPostTagsDatabase) Close(ctx context.Context) error

+ func (db *NullPostTagsDatabase) GetLikeIdsForDateRange(ctx context.Context, start int64, end int64, cb GetPostTagIdsCallbackFunc) error

+ func (db *NullPostTagsDatabase) GetPostTagWithId(ctx context.Context, id int64) (*activitypub.PostTag, error)

+ func (db *NullPostTagsDatabase) GetPostTagsForAccount(ctx context.Context, account_id int64, cb GetPostTagsCallbackFunc) error

+ func (db *NullPostTagsDatabase) GetPostTagsForName(ctx context.Context, name string, cb GetPostTagsCallbackFunc) error

+ func (db *NullPostTagsDatabase) GetPostTagsForPost(ctx context.Context, post_id int64, cb GetPostTagsCallbackFunc) error

+ func (db *NullPostTagsDatabase) RemovePostTag(ctx context.Context, boost *activitypub.PostTag) error

+ type NullPropertiesDatabase struct

+ func (db *NullPropertiesDatabase) AddProperty(ctx context.Context, property *activitypub.Property) error

+ func (db *NullPropertiesDatabase) Close(ctx context.Context) error

+ func (db *NullPropertiesDatabase) GetProperties(ctx context.Context, cb GetPropertiesCallbackFunc) error

+ func (db *NullPropertiesDatabase) GetPropertiesForAccount(ctx context.Context, account_id int64, cb GetPropertiesCallbackFunc) error

+ func (db *NullPropertiesDatabase) RemoveProperty(ctx context.Context, property *activitypub.Property) error

+ func (db *NullPropertiesDatabase) UpdateProperty(ctx context.Context, property *activitypub.Property) error

+ type PostTagsDatabase interface

+ AddPostTag func(context.Context, *activitypub.PostTag) error

+ Close func(context.Context) error

+ GetPostTagIdsForDateRange func(context.Context, int64, int64, GetPostTagIdsCallbackFunc) error

+ GetPostTagWithId func(context.Context, int64) (*activitypub.PostTag, error)

+ GetPostTagsForAccount func(context.Context, int64, GetPostTagsCallbackFunc) error

+ GetPostTagsForName func(context.Context, string, GetPostTagsCallbackFunc) error

+ GetPostTagsForPost func(context.Context, int64, GetPostTagsCallbackFunc) error

+ RemovePostTag func(context.Context, *activitypub.PostTag) error

+ func NewDocstorePostTagsDatabase(ctx context.Context, uri string) (PostTagsDatabase, error)

+ func NewNullPostTagsDatabase(ctx context.Context, uri string) (PostTagsDatabase, error)

+ func NewPostTagsDatabase(ctx context.Context, uri string) (PostTagsDatabase, error)

+ func NewSQLPostTagsDatabase(ctx context.Context, uri string) (PostTagsDatabase, error)

+ type PostTagsDatabaseInitializationFunc func(ctx context.Context, uri string) (PostTagsDatabase, error)

+ type PostsDatabase interface

+ AddPost func(context.Context, *activitypub.Post) error

+ Close func(context.Context) error

+ GetPostIdsForDateRange func(context.Context, int64, int64, GetPostIdsCallbackFunc) error

+ GetPostWithId func(context.Context, int64) (*activitypub.Post, error)

+ RemovePost func(context.Context, *activitypub.Post) error

+ UpdatePost func(context.Context, *activitypub.Post) error

+ func NewDocstorePostsDatabase(ctx context.Context, uri string) (PostsDatabase, error)

+ func NewPostsDatabase(ctx context.Context, uri string) (PostsDatabase, error)

+ func NewSQLPostsDatabase(ctx context.Context, uri string) (PostsDatabase, error)

+ type PostsDatabaseInitializationFunc func(ctx context.Context, uri string) (PostsDatabase, error)

+ type PropertiesDatabase interface

+ AddProperty func(context.Context, *activitypub.Property) error

+ Close func(context.Context) error

+ GetProperties func(context.Context, GetPropertiesCallbackFunc) error

+ GetPropertiesForAccount func(context.Context, int64, GetPropertiesCallbackFunc) error

+ RemoveProperty func(context.Context, *activitypub.Property) error

+ UpdateProperty func(context.Context, *activitypub.Property) error

+ func NewDocstorePropertiesDatabase(ctx context.Context, uri string) (PropertiesDatabase, error)

+ func NewNullPropertiesDatabase(ctx context.Context, uri string) (PropertiesDatabase, error)

+ func NewPropertiesDatabase(ctx context.Context, uri string) (PropertiesDatabase, error)

+ func NewSQLPropertiesDatabase(ctx context.Context, uri string) (PropertiesDatabase, error)

+ type PropertiesDatabaseInitializationFunc func(ctx context.Context, uri string) (PropertiesDatabase, error)

+ type SQLAccountsDatabase struct

+ func (db *SQLAccountsDatabase) AddAccount(ctx context.Context, a *activitypub.Account) error

+ func (db *SQLAccountsDatabase) Close(ctx context.Context) error

+ func (db *SQLAccountsDatabase) GetAccountIdsForDateRange(ctx context.Context, start int64, end int64, cb GetAccountIdsCallbackFunc) error

+ func (db *SQLAccountsDatabase) GetAccountWithId(ctx context.Context, id int64) (*activitypub.Account, error)

+ func (db *SQLAccountsDatabase) GetAccountWithName(ctx context.Context, name string) (*activitypub.Account, error)

+ func (db *SQLAccountsDatabase) GetAccounts(ctx context.Context, acct GetAccountsCallbackFunc) error

+ func (db *SQLAccountsDatabase) RemoveAccount(ctx context.Context, acct *activitypub.Account) error

+ func (db *SQLAccountsDatabase) UpdateAccount(ctx context.Context, acct *activitypub.Account) error

+ type SQLActivitiesDatabase struct

+ func (db *SQLActivitiesDatabase) AddActivity(ctx context.Context, a *activitypub.Activity) error

+ func (db *SQLActivitiesDatabase) Close(ctx context.Context) error

+ func (db *SQLActivitiesDatabase) GetActivities(ctx context.Context, cb GetActivitiesCallbackFunc) error

+ func (db *SQLActivitiesDatabase) GetActivitiesForAccount(ctx context.Context, id int64, cb GetActivitiesCallbackFunc) error

+ func (db *SQLActivitiesDatabase) GetActivityWithActivityPubId(ctx context.Context, id string) (*activitypub.Activity, error)

+ func (db *SQLActivitiesDatabase) GetActivityWithActivityTypeAndId(ctx context.Context, activity_type activitypub.ActivityType, ...) (*activitypub.Activity, error)

+ func (db *SQLActivitiesDatabase) GetActivityWithId(ctx context.Context, id int64) (*activitypub.Activity, error)

+ type SQLAliasesDatabase struct

+ func (db *SQLAliasesDatabase) AddAlias(ctx context.Context, alias *activitypub.Alias) error

+ func (db *SQLAliasesDatabase) Close(ctx context.Context) error

+ func (db *SQLAliasesDatabase) GetAliasWithName(ctx context.Context, name string) (*activitypub.Alias, error)

+ func (db *SQLAliasesDatabase) GetAliasesForAccount(ctx context.Context, account_id int64, cb GetAliasesCallbackFunc) error

+ func (db *SQLAliasesDatabase) RemoveAlias(ctx context.Context, alias *activitypub.Alias) error

+ type SQLBlocksDatabase struct

+ func (db *SQLBlocksDatabase) AddBlock(ctx context.Context, block *activitypub.Block) error

+ func (db *SQLBlocksDatabase) Close(ctx context.Context) error

+ func (db *SQLBlocksDatabase) GetBlockIdsForDateRange(ctx context.Context, start int64, end int64, cb GetBlockIdsCallbackFunc) error

+ func (db *SQLBlocksDatabase) GetBlockWithAccountIdAndAddress(ctx context.Context, account_id int64, host string, name string) (*activitypub.Block, error)

+ func (db *SQLBlocksDatabase) GetBlockWithId(ctx context.Context, block_id int64) (*activitypub.Block, error)

+ func (db *SQLBlocksDatabase) RemoveBlock(ctx context.Context, block *activitypub.Block) error

+ func (db *SQLBlocksDatabase) UpdateBlock(ctx context.Context, block *activitypub.Block) error

+ type SQLBoostsDatabase struct

+ func (db *SQLBoostsDatabase) AddBoost(ctx context.Context, b *activitypub.Boost) error

+ func (db *SQLBoostsDatabase) Close(ctx context.Context) error

+ func (db *SQLBoostsDatabase) GetBoostWithId(ctx context.Context, id int64) (*activitypub.Boost, error)

+ func (db *SQLBoostsDatabase) GetBoostWithPostIdAndActor(ctx context.Context, post_id int64, actor string) (*activitypub.Boost, error)

+ func (db *SQLBoostsDatabase) GetBoostsForAccount(ctx context.Context, account_id int64, cb GetBoostsCallbackFunc) error

+ func (db *SQLBoostsDatabase) GetBoostsForPostIdAndActor(ctx context.Context, post_id int64, actor string, cb GetBoostsCallbackFunc) error

+ func (db *SQLBoostsDatabase) GetBoostsForPosts(ctx context.Context, post_id int64, cb GetBoostsCallbackFunc) error

+ func (db *SQLBoostsDatabase) RemoveBoost(ctx context.Context, b *activitypub.Boost) error

+ type SQLDeliveriesDatabase struct

+ func (db *SQLDeliveriesDatabase) AddDelivery(ctx context.Context, d *activitypub.Delivery) error

+ func (db *SQLDeliveriesDatabase) Close(ctx context.Context) error

+ func (db *SQLDeliveriesDatabase) GetDeliveries(ctx context.Context, cb GetDeliveriesCallbackFunc) error

+ func (db *SQLDeliveriesDatabase) GetDeliveriesWithActivityIdAndRecipient(ctx context.Context, activity_id int64, recipient string, ...) error

+ func (db *SQLDeliveriesDatabase) GetDeliveriesWithActivityPubIdAndRecipient(ctx context.Context, activitypub_id string, recipient string, ...) error

+ func (db *SQLDeliveriesDatabase) GetDeliveryIdsForDateRange(ctx context.Context, start int64, end int64, cb GetDeliveryIdsCallbackFunc) error

+ func (db *SQLDeliveriesDatabase) GetDeliveryWithId(ctx context.Context, id int64) (*activitypub.Delivery, error)

+ type SQLFollowersDatabase struct

+ func (db *SQLFollowersDatabase) AddFollower(ctx context.Context, f *activitypub.Follower) error

+ func (db *SQLFollowersDatabase) Close(ctx context.Context) error

+ func (db *SQLFollowersDatabase) GetAllFollowers(ctx context.Context, followers_callback GetFollowersCallbackFunc) error

+ func (db *SQLFollowersDatabase) GetFollower(ctx context.Context, account_id int64, follower_address string) (*activitypub.Follower, error)

+ func (db *SQLFollowersDatabase) GetFollowerIdsForDateRange(ctx context.Context, start int64, end int64, cb GetFollowerIdsCallbackFunc) error

+ func (db *SQLFollowersDatabase) GetFollowersForAccount(ctx context.Context, account_id int64, ...) error

+ func (db *SQLFollowersDatabase) HasFollower(ctx context.Context, account_id int64, follower_address string) (bool, error)

+ func (db *SQLFollowersDatabase) RemoveFollower(ctx context.Context, f *activitypub.Follower) error

+ type SQLFollowingDatabase struct

+ func (db *SQLFollowingDatabase) AddFollowing(ctx context.Context, f *activitypub.Following) error

+ func (db *SQLFollowingDatabase) Close(ctx context.Context) error

+ func (db *SQLFollowingDatabase) GetFollowing(ctx context.Context, account_id int64, following_address string) (*activitypub.Following, error)

+ func (db *SQLFollowingDatabase) GetFollowingForAccount(ctx context.Context, account_id int64, ...) error

+ func (db *SQLFollowingDatabase) GetFollowingIdsForDateRange(ctx context.Context, start int64, end int64, cb GetFollowingIdsCallbackFunc) error

+ func (db *SQLFollowingDatabase) RemoveFollowing(ctx context.Context, f *activitypub.Following) error

+ type SQLLikesDatabase struct

+ func (db *SQLLikesDatabase) AddLike(ctx context.Context, b *activitypub.Like) error

+ func (db *SQLLikesDatabase) Close(ctx context.Context) error

+ func (db *SQLLikesDatabase) GetLikeIdsForDateRange(ctx context.Context, start int64, end int64, cb GetLikeIdsCallbackFunc) error

+ func (db *SQLLikesDatabase) GetLikeWithId(ctx context.Context, id int64) (*activitypub.Like, error)

+ func (db *SQLLikesDatabase) GetLikeWithPostIdAndActor(ctx context.Context, post_id int64, actor string) (*activitypub.Like, error)

+ func (db *SQLLikesDatabase) GetLikesForPostIdAndActor(ctx context.Context, post_id int64, actor string, cb GetLikesCallbackFunc) error

+ func (db *SQLLikesDatabase) RemoveLike(ctx context.Context, b *activitypub.Like) error

+ type SQLMessagesDatabase struct

+ func (db *SQLMessagesDatabase) AddMessage(ctx context.Context, message *activitypub.Message) error

+ func (db *SQLMessagesDatabase) Close(ctx context.Context) error

+ func (db *SQLMessagesDatabase) GetMessageIdsForDateRange(ctx context.Context, start int64, end int64, cb GetMessageIdsCallbackFunc) error

+ func (db *SQLMessagesDatabase) GetMessageWithAccountAndNoteIds(ctx context.Context, account_id int64, note_id int64) (*activitypub.Message, error)

+ func (db *SQLMessagesDatabase) GetMessageWithId(ctx context.Context, message_id int64) (*activitypub.Message, error)

+ func (db *SQLMessagesDatabase) GetMessagesForAccount(ctx context.Context, account_id int64, callback_func GetMessagesCallbackFunc) error

+ func (db *SQLMessagesDatabase) GetMessagesForAccountAndAuthor(ctx context.Context, account_id int64, author_address string, ...) error

+ func (db *SQLMessagesDatabase) RemoveMessage(ctx context.Context, message *activitypub.Message) error

+ func (db *SQLMessagesDatabase) UpdateMessage(ctx context.Context, message *activitypub.Message) error

+ type SQLNotesDatabase struct

+ func (db *SQLNotesDatabase) AddNote(ctx context.Context, note *activitypub.Note) error

+ func (db *SQLNotesDatabase) Close(ctx context.Context) error

+ func (db *SQLNotesDatabase) GetNoteIdsForDateRange(ctx context.Context, start int64, end int64, cb GetNoteIdsCallbackFunc) error

+ func (db *SQLNotesDatabase) GetNoteWithId(ctx context.Context, note_id int64) (*activitypub.Note, error)

+ func (db *SQLNotesDatabase) GetNoteWithUUIDAndAuthorAddress(ctx context.Context, uuid string, author_address string) (*activitypub.Note, error)

+ func (db *SQLNotesDatabase) RemoveNote(ctx context.Context, note *activitypub.Note) error

+ func (db *SQLNotesDatabase) UpdateNote(ctx context.Context, note *activitypub.Note) error

+ type SQLPostTagsDatabase struct

+ func (db *SQLPostTagsDatabase) AddPostTag(ctx context.Context, post_tag *activitypub.PostTag) error

+ func (db *SQLPostTagsDatabase) Close(ctx context.Context) error

+ func (db *SQLPostTagsDatabase) GetPostTagIdsForDateRange(ctx context.Context, start int64, end int64, cb GetPostTagIdsCallbackFunc) error

+ func (db *SQLPostTagsDatabase) GetPostTagWithId(ctx context.Context, id int64) (*activitypub.PostTag, error)

+ func (db *SQLPostTagsDatabase) GetPostTagsForAccount(ctx context.Context, account_id int64, cb GetPostTagsCallbackFunc) error

+ func (db *SQLPostTagsDatabase) GetPostTagsForName(ctx context.Context, name string, cb GetPostTagsCallbackFunc) error

+ func (db *SQLPostTagsDatabase) GetPostTagsForPost(ctx context.Context, post_id int64, cb GetPostTagsCallbackFunc) error

+ func (db *SQLPostTagsDatabase) RemovePostTag(ctx context.Context, post_tag *activitypub.PostTag) error

+ type SQLPostsDatabase struct

+ func (db *SQLPostsDatabase) AddPost(ctx context.Context, p *activitypub.Post) error

+ func (db *SQLPostsDatabase) Close(ctx context.Context) error

+ func (db *SQLPostsDatabase) GetPostIdsForDateRange(ctx context.Context, start int64, end int64, cb GetPostIdsCallbackFunc) error

+ func (db *SQLPostsDatabase) GetPostWithId(ctx context.Context, id int64) (*activitypub.Post, error)

+ type SQLPropertiesDatabase struct

+ func (db *SQLPropertiesDatabase) AddProperty(ctx context.Context, property *activitypub.Property) error

+ func (db *SQLPropertiesDatabase) Close(ctx context.Context) error

+ func (db *SQLPropertiesDatabase) GetProperties(ctx context.Context, cb GetPropertiesCallbackFunc) error

+ func (db *SQLPropertiesDatabase) GetPropertiesForAccount(ctx context.Context, account_id int64, cb GetPropertiesCallbackFunc) error

+ func (db *SQLPropertiesDatabase) RemoveProperty(ctx context.Context, property *activitypub.Property) error

+ func (db *SQLPropertiesDatabase) UpdateProperty(ctx context.Context, property *activitypub.Property) error

+ type SlogDeliveriesDatabase struct

+ func (db *SlogDeliveriesDatabase) AddDelivery(ctx context.Context, d *activitypub.Delivery) error

+ func (db *SlogDeliveriesDatabase) Close(ctx context.Context) error

+ func (db *SlogDeliveriesDatabase) GetDeliveries(ctx context.Context, cb GetDeliveriesCallbackFunc) error

+ func (db *SlogDeliveriesDatabase) GetDeliveriesWithActivityIdAndRecipient(ctx context.Context, activity_id int64, recipient string, ...) error

+ func (db *SlogDeliveriesDatabase) GetDeliveriesWithActivityPubIdAndRecipient(ctx context.Context, activity_pub_id string, recipient string, ...) error

+ func (db *SlogDeliveriesDatabase) GetDeliveryIdsForDateRange(ctx context.Context, start int64, end int64, cb GetDeliveryIdsCallbackFunc) error

+ func (db *SlogDeliveriesDatabase) GetDeliveryWithId(ctx context.Context, id int64) (*activitypub.Delivery, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL