database

Documentation

Index

• type ChannelPlugin
  • func (p *ChannelPlugin) Init(options *plug.Options)
  • func (p *ChannelPlugin) RequireOptions() []string
• type Config
  • func (c *Config) DBNameOrSystem() string
• type Database
  • func New() *Database
  • func (database *Database) GetDB(context *core.Context) *aorm.DB
  • func (database *Database) GetNotification(user common.User, notificationID string, _ *notification.Notification, ...) (*notification.QorNotification, error)
  • func (database *Database) GetNotifications(user common.User, results *notification.NotificationsResult, ...) error
  • func (database *Database) GetUnresolvedNotificationsCount(user common.User, _ *notification.Notification, context *core.Context) uint
  • func (database *Database) Send(message *notification.Message, context *core.Context) error
  • func (d *Database) Setup(db *aorm.DB) error

Types

type ChannelPlugin

type ChannelPlugin struct {
	NotificationKey string
}

func (*ChannelPlugin) Init

func (p *ChannelPlugin) Init(options *plug.Options)

func (*ChannelPlugin) RequireOptions

func (p *ChannelPlugin) RequireOptions() []string

type Config

type Config struct {
	DBName string
}

func (*Config) DBNameOrSystem

func (c *Config) DBNameOrSystem() string

type Database

type Database struct {
	Config *Config
}

func New

func New() *Database

func (*Database) GetDB

func (database *Database) GetDB(context *core.Context) *aorm.DB

func (*Database) GetNotification

func (database *Database) GetNotification(user common.User, notificationID string, _ *notification.Notification, context *core.Context) (*notification.QorNotification, error)

func (*Database) GetNotifications

func (database *Database) GetNotifications(user common.User, results *notification.NotificationsResult, _ *notification.Notification, context *core.Context) error

func (*Database) GetUnresolvedNotificationsCount

func (database *Database) GetUnresolvedNotificationsCount(user common.User, _ *notification.Notification, context *core.Context) uint

func (*Database) Send

func (database *Database) Send(message *notification.Message, context *core.Context) error

func (*Database) Setup

func (d *Database) Setup(db *aorm.DB) error