measuredrepository

Documentation

Index

• func New(rep repository.Repository) repository.Repository
• type Measured
  • func (m *Measured) CapabilitiesExist(ctx context.Context, node, ver string) (ok bool, err error)
  • func (m *Measured) CountOfflineMessages(ctx context.Context, username string) (int, error)
  • func (m *Measured) DeleteArchive(ctx context.Context, archiveID string) error
  • func (m *Measured) DeleteArchiveOldestMessages(ctx context.Context, archiveID string, maxElements int) error
  • func (m *Measured) DeleteBlockListItem(ctx context.Context, item *blocklistmodel.Item) (err error)
  • func (m *Measured) DeleteBlockListItems(ctx context.Context, username string) (err error)
  • func (m *Measured) DeleteLast(ctx context.Context, username string) error
  • func (m *Measured) DeleteOfflineMessages(ctx context.Context, username string) error
  • func (m *Measured) DeletePrivates(ctx context.Context, username string) (err error)
  • func (m *Measured) DeleteRosterItem(ctx context.Context, username, jid string) error
  • func (m *Measured) DeleteRosterItems(ctx context.Context, username string) error
  • func (m *Measured) DeleteRosterNotification(ctx context.Context, contact, jid string) error
  • func (m *Measured) DeleteRosterNotifications(ctx context.Context, contact string) error
  • func (m *Measured) DeleteUser(ctx context.Context, username string) (err error)
  • func (m *Measured) DeleteVCard(ctx context.Context, username string) (err error)
  • func (m *Measured) FetchArchiveMessages(ctx context.Context, f *archivemodel.Filters, archiveID string) (messages []*archivemodel.Message, err error)
  • func (m *Measured) FetchArchiveMetadata(ctx context.Context, archiveID string) (metadata *archivemodel.Metadata, err error)
  • func (m *Measured) FetchBlockListItems(ctx context.Context, username string) (blockList []*blocklistmodel.Item, err error)
  • func (m *Measured) FetchCapabilities(ctx context.Context, node, ver string) (caps *capsmodel.Capabilities, err error)
  • func (m *Measured) FetchLast(ctx context.Context, username string) (last *lastmodel.Last, err error)
  • func (m *Measured) FetchOfflineMessages(ctx context.Context, username string) ([]*stravaganza.Message, error)
  • func (m *Measured) FetchPrivate(ctx context.Context, namespace, username string) (private stravaganza.Element, err error)
  • func (m *Measured) FetchRosterGroups(ctx context.Context, username string) ([]string, error)
  • func (m *Measured) FetchRosterItem(ctx context.Context, username, jid string) (*rostermodel.Item, error)
  • func (m *Measured) FetchRosterItems(ctx context.Context, username string) ([]*rostermodel.Item, error)
  • func (m *Measured) FetchRosterItemsInGroups(ctx context.Context, username string, groups []string) ([]*rostermodel.Item, error)
  • func (m *Measured) FetchRosterNotification(ctx context.Context, contact string, jid string) (*rostermodel.Notification, error)
  • func (m *Measured) FetchRosterNotifications(ctx context.Context, contact string) ([]*rostermodel.Notification, error)
  • func (m *Measured) FetchRosterVersion(ctx context.Context, username string) (int, error)
  • func (m *Measured) FetchUser(ctx context.Context, username string) (usr *usermodel.User, err error)
  • func (m *Measured) FetchVCard(ctx context.Context, username string) (stravaganza.Element, error)
  • func (m *Measured) InTransaction(ctx context.Context, ...) error
  • func (m *Measured) InsertArchiveMessage(ctx context.Context, message *archivemodel.Message) error
  • func (m *Measured) InsertOfflineMessage(ctx context.Context, message *stravaganza.Message, username string) error
  • func (m *Measured) Lock(ctx context.Context, lockID string) error
  • func (m *Measured) Start(ctx context.Context) error
  • func (m *Measured) Stop(ctx context.Context) error
  • func (m *Measured) TouchRosterVersion(ctx context.Context, username string) (int, error)
  • func (m *Measured) Unlock(ctx context.Context, lockID string) error
  • func (m *Measured) UpsertBlockListItem(ctx context.Context, item *blocklistmodel.Item) (err error)
  • func (m *Measured) UpsertCapabilities(ctx context.Context, caps *capsmodel.Capabilities) (err error)
  • func (m *Measured) UpsertLast(ctx context.Context, last *lastmodel.Last) error
  • func (m *Measured) UpsertPrivate(ctx context.Context, private stravaganza.Element, namespace, username string) (err error)
  • func (m *Measured) UpsertRosterItem(ctx context.Context, ri *rostermodel.Item) error
  • func (m *Measured) UpsertRosterNotification(ctx context.Context, rn *rostermodel.Notification) error
  • func (m *Measured) UpsertUser(ctx context.Context, user *usermodel.User) (err error)
  • func (m *Measured) UpsertVCard(ctx context.Context, vCard stravaganza.Element, username string) error
  • func (m *Measured) UserExists(ctx context.Context, username string) (ok bool, err error)

Functions

func New

func New(rep repository.Repository) repository.Repository

New returns a new initialized Measured repository.

Types

type Measured

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

Measured is measured Repository implementation.

func (*Measured) CapabilitiesExist

func (m *Measured) CapabilitiesExist(ctx context.Context, node, ver string) (ok bool, err error)

func (*Measured) CountOfflineMessages

func (m *Measured) CountOfflineMessages(ctx context.Context, username string) (int, error)

func (*Measured) DeleteArchive

func (m *Measured) DeleteArchive(ctx context.Context, archiveID string) error

func (*Measured) DeleteArchiveOldestMessages

func (m *Measured) DeleteArchiveOldestMessages(ctx context.Context, archiveID string, maxElements int) error

func (*Measured) DeleteBlockListItem

func (m *Measured) DeleteBlockListItem(ctx context.Context, item *blocklistmodel.Item) (err error)

func (*Measured) DeleteBlockListItems

func (m *Measured) DeleteBlockListItems(ctx context.Context, username string) (err error)

func (*Measured) DeleteLast

func (m *Measured) DeleteLast(ctx context.Context, username string) error

func (*Measured) DeleteOfflineMessages

func (m *Measured) DeleteOfflineMessages(ctx context.Context, username string) error

func (*Measured) DeletePrivates

func (m *Measured) DeletePrivates(ctx context.Context, username string) (err error)

func (*Measured) DeleteRosterItem

func (m *Measured) DeleteRosterItem(ctx context.Context, username, jid string) error

func (*Measured) DeleteRosterItems

func (m *Measured) DeleteRosterItems(ctx context.Context, username string) error

func (*Measured) DeleteRosterNotification

func (m *Measured) DeleteRosterNotification(ctx context.Context, contact, jid string) error

func (*Measured) DeleteRosterNotifications

func (m *Measured) DeleteRosterNotifications(ctx context.Context, contact string) error

func (*Measured) DeleteUser

func (m *Measured) DeleteUser(ctx context.Context, username string) (err error)

func (*Measured) DeleteVCard

func (m *Measured) DeleteVCard(ctx context.Context, username string) (err error)

func (*Measured) FetchArchiveMessages

func (m *Measured) FetchArchiveMessages(ctx context.Context, f *archivemodel.Filters, archiveID string) (messages []*archivemodel.Message, err error)

func (*Measured) FetchArchiveMetadata

func (m *Measured) FetchArchiveMetadata(ctx context.Context, archiveID string) (metadata *archivemodel.Metadata, err error)

func (*Measured) FetchBlockListItems

func (m *Measured) FetchBlockListItems(ctx context.Context, username string) (blockList []*blocklistmodel.Item, err error)

func (*Measured) FetchCapabilities

func (m *Measured) FetchCapabilities(ctx context.Context, node, ver string) (caps *capsmodel.Capabilities, err error)

func (*Measured) FetchLast

func (m *Measured) FetchLast(ctx context.Context, username string) (last *lastmodel.Last, err error)

func (*Measured) FetchOfflineMessages

func (m *Measured) FetchOfflineMessages(ctx context.Context, username string) ([]*stravaganza.Message, error)

func (*Measured) FetchPrivate

func (m *Measured) FetchPrivate(ctx context.Context, namespace, username string) (private stravaganza.Element, err error)

func (*Measured) FetchRosterGroups

func (m *Measured) FetchRosterGroups(ctx context.Context, username string) ([]string, error)

func (*Measured) FetchRosterItem

func (m *Measured) FetchRosterItem(ctx context.Context, username, jid string) (*rostermodel.Item, error)

func (*Measured) FetchRosterItems

func (m *Measured) FetchRosterItems(ctx context.Context, username string) ([]*rostermodel.Item, error)

func (*Measured) FetchRosterItemsInGroups

func (m *Measured) FetchRosterItemsInGroups(ctx context.Context, username string, groups []string) ([]*rostermodel.Item, error)

func (*Measured) FetchRosterNotification

func (m *Measured) FetchRosterNotification(ctx context.Context, contact string, jid string) (*rostermodel.Notification, error)

func (*Measured) FetchRosterNotifications

func (m *Measured) FetchRosterNotifications(ctx context.Context, contact string) ([]*rostermodel.Notification, error)

func (*Measured) FetchRosterVersion

func (m *Measured) FetchRosterVersion(ctx context.Context, username string) (int, error)

func (*Measured) FetchUser

func (m *Measured) FetchUser(ctx context.Context, username string) (usr *usermodel.User, err error)

func (*Measured) FetchVCard

func (m *Measured) FetchVCard(ctx context.Context, username string) (stravaganza.Element, error)

func (*Measured) InTransaction

func (m *Measured) InTransaction(ctx context.Context, f func(ctx context.Context, tx repository.Transaction) error) error

InTransaction generates a repository transaction and completes it after it's being used by f function. In case f returns no error tx transaction will be committed.

func (*Measured) InsertArchiveMessage

func (m *Measured) InsertArchiveMessage(ctx context.Context, message *archivemodel.Message) error

func (*Measured) InsertOfflineMessage

func (m *Measured) InsertOfflineMessage(ctx context.Context, message *stravaganza.Message, username string) error

func (*Measured) Lock

func (m *Measured) Lock(ctx context.Context, lockID string) error

func (*Measured) Start

func (m *Measured) Start(ctx context.Context) error

Start initializes repository.

func (*Measured) Stop

func (m *Measured) Stop(ctx context.Context) error

Stop releases all underlying repository resources.

func (*Measured) TouchRosterVersion

func (m *Measured) TouchRosterVersion(ctx context.Context, username string) (int, error)

func (*Measured) Unlock

func (m *Measured) Unlock(ctx context.Context, lockID string) error

func (*Measured) UpsertBlockListItem

func (m *Measured) UpsertBlockListItem(ctx context.Context, item *blocklistmodel.Item) (err error)

func (*Measured) UpsertCapabilities

func (m *Measured) UpsertCapabilities(ctx context.Context, caps *capsmodel.Capabilities) (err error)

func (*Measured) UpsertLast

func (m *Measured) UpsertLast(ctx context.Context, last *lastmodel.Last) error

func (*Measured) UpsertPrivate

func (m *Measured) UpsertPrivate(ctx context.Context, private stravaganza.Element, namespace, username string) (err error)

func (*Measured) UpsertRosterItem

func (m *Measured) UpsertRosterItem(ctx context.Context, ri *rostermodel.Item) error

func (*Measured) UpsertRosterNotification

func (m *Measured) UpsertRosterNotification(ctx context.Context, rn *rostermodel.Notification) error

func (*Measured) UpsertUser

func (m *Measured) UpsertUser(ctx context.Context, user *usermodel.User) (err error)

func (*Measured) UpsertVCard

func (m *Measured) UpsertVCard(ctx context.Context, vCard stravaganza.Element, username string) error

func (*Measured) UserExists

func (m *Measured) UserExists(ctx context.Context, username string) (ok bool, err error)