postgres

Documentation

Index

• func NewDB(profile *profile.Profile) (store.Driver, error)
• type DB
  • func (d *DB) Close() error
  • func (d *DB) CreateActivity(ctx context.Context, create *store.Activity) (*store.Activity, error)
  • func (d *DB) CreateIdentityProvider(ctx context.Context, create *store.IdentityProvider) (*store.IdentityProvider, error)
  • func (d *DB) CreateInbox(ctx context.Context, create *store.Inbox) (*store.Inbox, error)
  • func (d *DB) CreateMemo(ctx context.Context, create *store.Memo) (*store.Memo, error)
  • func (d *DB) CreateResource(ctx context.Context, create *store.Resource) (*store.Resource, error)
  • func (d *DB) CreateUser(ctx context.Context, create *store.User) (*store.User, error)
  • func (d *DB) CreateWebhook(ctx context.Context, create *store.Webhook) (*store.Webhook, error)
  • func (d *DB) DeleteIdentityProvider(ctx context.Context, delete *store.DeleteIdentityProvider) error
  • func (d *DB) DeleteInbox(ctx context.Context, delete *store.DeleteInbox) error
  • func (d *DB) DeleteMemo(ctx context.Context, delete *store.DeleteMemo) error
  • func (d *DB) DeleteMemoOrganizer(ctx context.Context, delete *store.DeleteMemoOrganizer) error
  • func (d *DB) DeleteMemoRelation(ctx context.Context, delete *store.DeleteMemoRelation) error
  • func (d *DB) DeleteReaction(ctx context.Context, delete *store.DeleteReaction) error
  • func (d *DB) DeleteResource(ctx context.Context, delete *store.DeleteResource) error
  • func (d *DB) DeleteUser(ctx context.Context, delete *store.DeleteUser) error
  • func (d *DB) DeleteWebhook(ctx context.Context, delete *store.DeleteWebhook) error
  • func (d *DB) DeleteWorkspaceSetting(ctx context.Context, delete *store.DeleteWorkspaceSetting) error
  • func (d *DB) FindMigrationHistoryList(ctx context.Context, _ *store.FindMigrationHistory) ([]*store.MigrationHistory, error)
  • func (*DB) GetCurrentDBSize(context.Context) (int64, error)
  • func (d *DB) GetDB() *sql.DB
  • func (d *DB) GetInbox(ctx context.Context, find *store.FindInbox) (*store.Inbox, error)
  • func (d *DB) GetMemo(ctx context.Context, find *store.FindMemo) (*store.Memo, error)
  • func (d *DB) ListActivities(ctx context.Context, find *store.FindActivity) ([]*store.Activity, error)
  • func (d *DB) ListIdentityProviders(ctx context.Context, find *store.FindIdentityProvider) ([]*store.IdentityProvider, error)
  • func (d *DB) ListInboxes(ctx context.Context, find *store.FindInbox) ([]*store.Inbox, error)
  • func (d *DB) ListMemoOrganizer(ctx context.Context, find *store.FindMemoOrganizer) ([]*store.MemoOrganizer, error)
  • func (d *DB) ListMemoRelations(ctx context.Context, find *store.FindMemoRelation) ([]*store.MemoRelation, error)
  • func (d *DB) ListMemos(ctx context.Context, find *store.FindMemo) ([]*store.Memo, error)
  • func (d *DB) ListReactions(ctx context.Context, find *store.FindReaction) ([]*store.Reaction, error)
  • func (d *DB) ListResources(ctx context.Context, find *store.FindResource) ([]*store.Resource, error)
  • func (d *DB) ListUserSettings(ctx context.Context, find *store.FindUserSetting) ([]*store.UserSetting, error)
  • func (d *DB) ListUsers(ctx context.Context, find *store.FindUser) ([]*store.User, error)
  • func (d *DB) ListWebhooks(ctx context.Context, find *store.FindWebhook) ([]*store.Webhook, error)
  • func (d *DB) ListWorkspaceSettings(ctx context.Context, find *store.FindWorkspaceSetting) ([]*store.WorkspaceSetting, error)
  • func (d *DB) Migrate(ctx context.Context) error
  • func (d *DB) UpdateIdentityProvider(ctx context.Context, update *store.UpdateIdentityProvider) (*store.IdentityProvider, error)
  • func (d *DB) UpdateInbox(ctx context.Context, update *store.UpdateInbox) (*store.Inbox, error)
  • func (d *DB) UpdateMemo(ctx context.Context, update *store.UpdateMemo) error
  • func (d *DB) UpdateResource(ctx context.Context, update *store.UpdateResource) error
  • func (d *DB) UpdateUser(ctx context.Context, update *store.UpdateUser) (*store.User, error)
  • func (d *DB) UpdateWebhook(ctx context.Context, update *store.UpdateWebhook) (*store.Webhook, error)
  • func (d *DB) UpsertMemoOrganizer(ctx context.Context, upsert *store.MemoOrganizer) (*store.MemoOrganizer, error)
  • func (d *DB) UpsertMemoRelation(ctx context.Context, create *store.MemoRelation) (*store.MemoRelation, error)
  • func (d *DB) UpsertMigrationHistory(ctx context.Context, upsert *store.UpsertMigrationHistory) (*store.MigrationHistory, error)
  • func (d *DB) UpsertReaction(ctx context.Context, upsert *store.Reaction) (*store.Reaction, error)
  • func (d *DB) UpsertUserSetting(ctx context.Context, upsert *store.UserSetting) (*store.UserSetting, error)
  • func (d *DB) UpsertWorkspaceSetting(ctx context.Context, upsert *store.WorkspaceSetting) (*store.WorkspaceSetting, error)

Functions

func NewDB

func NewDB(profile *profile.Profile) (store.Driver, error)

Types

type DB

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

func (*DB) Close

func (d *DB) Close() error

func (*DB) CreateActivity

func (d *DB) CreateActivity(ctx context.Context, create *store.Activity) (*store.Activity, error)

func (*DB) CreateIdentityProvider

func (d *DB) CreateIdentityProvider(ctx context.Context, create *store.IdentityProvider) (*store.IdentityProvider, error)

func (*DB) CreateInbox

func (d *DB) CreateInbox(ctx context.Context, create *store.Inbox) (*store.Inbox, error)

func (*DB) CreateMemo

func (d *DB) CreateMemo(ctx context.Context, create *store.Memo) (*store.Memo, error)

func (*DB) CreateResource

func (d *DB) CreateResource(ctx context.Context, create *store.Resource) (*store.Resource, error)

func (*DB) CreateUser

func (d *DB) CreateUser(ctx context.Context, create *store.User) (*store.User, error)

func (*DB) CreateWebhook

func (d *DB) CreateWebhook(ctx context.Context, create *store.Webhook) (*store.Webhook, error)

func (*DB) DeleteIdentityProvider

func (d *DB) DeleteIdentityProvider(ctx context.Context, delete *store.DeleteIdentityProvider) error

func (*DB) DeleteInbox

func (d *DB) DeleteInbox(ctx context.Context, delete *store.DeleteInbox) error

func (*DB) DeleteMemo

func (d *DB) DeleteMemo(ctx context.Context, delete *store.DeleteMemo) error

func (*DB) DeleteMemoOrganizer

func (d *DB) DeleteMemoOrganizer(ctx context.Context, delete *store.DeleteMemoOrganizer) error

func (*DB) DeleteMemoRelation

func (d *DB) DeleteMemoRelation(ctx context.Context, delete *store.DeleteMemoRelation) error

func (*DB) DeleteReaction

func (d *DB) DeleteReaction(ctx context.Context, delete *store.DeleteReaction) error

func (*DB) DeleteResource

func (d *DB) DeleteResource(ctx context.Context, delete *store.DeleteResource) error

func (*DB) DeleteUser

func (d *DB) DeleteUser(ctx context.Context, delete *store.DeleteUser) error

func (*DB) DeleteWebhook

func (d *DB) DeleteWebhook(ctx context.Context, delete *store.DeleteWebhook) error

func (*DB) DeleteWorkspaceSetting

func (d *DB) DeleteWorkspaceSetting(ctx context.Context, delete *store.DeleteWorkspaceSetting) error

func (*DB) FindMigrationHistoryList

func (d *DB) FindMigrationHistoryList(ctx context.Context, _ *store.FindMigrationHistory) ([]*store.MigrationHistory, error)

func (*DB) GetCurrentDBSize

func (*DB) GetCurrentDBSize(context.Context) (int64, error)

func (*DB) GetDB

func (d *DB) GetDB() *sql.DB

func (*DB) GetInbox

func (d *DB) GetInbox(ctx context.Context, find *store.FindInbox) (*store.Inbox, error)

func (*DB) GetMemo

func (d *DB) GetMemo(ctx context.Context, find *store.FindMemo) (*store.Memo, error)

func (*DB) ListActivities

func (d *DB) ListActivities(ctx context.Context, find *store.FindActivity) ([]*store.Activity, error)

func (*DB) ListIdentityProviders

func (d *DB) ListIdentityProviders(ctx context.Context, find *store.FindIdentityProvider) ([]*store.IdentityProvider, error)

func (*DB) ListInboxes

func (d *DB) ListInboxes(ctx context.Context, find *store.FindInbox) ([]*store.Inbox, error)

func (*DB) ListMemoOrganizer

func (d *DB) ListMemoOrganizer(ctx context.Context, find *store.FindMemoOrganizer) ([]*store.MemoOrganizer, error)

func (*DB) ListMemoRelations

func (d *DB) ListMemoRelations(ctx context.Context, find *store.FindMemoRelation) ([]*store.MemoRelation, error)

func (*DB) ListMemos

func (d *DB) ListMemos(ctx context.Context, find *store.FindMemo) ([]*store.Memo, error)

func (*DB) ListReactions

func (d *DB) ListReactions(ctx context.Context, find *store.FindReaction) ([]*store.Reaction, error)

func (*DB) ListResources

func (d *DB) ListResources(ctx context.Context, find *store.FindResource) ([]*store.Resource, error)

func (*DB) ListUserSettings

func (d *DB) ListUserSettings(ctx context.Context, find *store.FindUserSetting) ([]*store.UserSetting, error)

func (*DB) ListUsers

func (d *DB) ListUsers(ctx context.Context, find *store.FindUser) ([]*store.User, error)

func (*DB) ListWebhooks

func (d *DB) ListWebhooks(ctx context.Context, find *store.FindWebhook) ([]*store.Webhook, error)

func (*DB) ListWorkspaceSettings

func (d *DB) ListWorkspaceSettings(ctx context.Context, find *store.FindWorkspaceSetting) ([]*store.WorkspaceSetting, error)

func (*DB) Migrate

func (d *DB) Migrate(ctx context.Context) error

func (*DB) UpdateIdentityProvider

func (d *DB) UpdateIdentityProvider(ctx context.Context, update *store.UpdateIdentityProvider) (*store.IdentityProvider, error)

func (*DB) UpdateInbox

func (d *DB) UpdateInbox(ctx context.Context, update *store.UpdateInbox) (*store.Inbox, error)

func (*DB) UpdateMemo

func (d *DB) UpdateMemo(ctx context.Context, update *store.UpdateMemo) error

func (*DB) UpdateResource

func (d *DB) UpdateResource(ctx context.Context, update *store.UpdateResource) error

func (*DB) UpdateUser

func (d *DB) UpdateUser(ctx context.Context, update *store.UpdateUser) (*store.User, error)

func (*DB) UpdateWebhook

func (d *DB) UpdateWebhook(ctx context.Context, update *store.UpdateWebhook) (*store.Webhook, error)

func (*DB) UpsertMemoOrganizer

func (d *DB) UpsertMemoOrganizer(ctx context.Context, upsert *store.MemoOrganizer) (*store.MemoOrganizer, error)

func (*DB) UpsertMemoRelation

func (d *DB) UpsertMemoRelation(ctx context.Context, create *store.MemoRelation) (*store.MemoRelation, error)

func (*DB) UpsertMigrationHistory

func (d *DB) UpsertMigrationHistory(ctx context.Context, upsert *store.UpsertMigrationHistory) (*store.MigrationHistory, error)

func (*DB) UpsertReaction

func (d *DB) UpsertReaction(ctx context.Context, upsert *store.Reaction) (*store.Reaction, error)

func (*DB) UpsertUserSetting

func (d *DB) UpsertUserSetting(ctx context.Context, upsert *store.UserSetting) (*store.UserSetting, error)

func (*DB) UpsertWorkspaceSetting

func (d *DB) UpsertWorkspaceSetting(ctx context.Context, upsert *store.WorkspaceSetting) (*store.WorkspaceSetting, error)