notify

Documentation

Index

• type ChatDB
  • func NewChatDB(db db.ChatDB, logged db.LoggedDB, ch chan<- events.Event) *ChatDB
  • func (d *ChatDB) Add(chatname string) error
  • func (d *ChatDB) AddUser(chatname, username string) error
  • func (d *ChatDB) Remove(chatname string) error
  • func (d *ChatDB) RemoveUser(chatname, username string) error
  • func (d *ChatDB) StartListeningToEvents(ch <-chan events.Event)
• type LoggedDB
  • func NewLoggedDB(db db.LoggedDB, ch chan<- events.Event) *LoggedDB
  • func (d *LoggedDB) Login(username string) (*models.LoggedUser, error)
  • func (d *LoggedDB) Logout(username string) error
• type MessageDB
  • func NewMessageDB(db db.MessageDB, ch chan<- events.Event) *MessageDB
  • func (d *MessageDB) Post(msg *models.Message) error

Types

type ChatDB

type ChatDB struct {
	db.ChatDB
	// contains filtered or unexported fields
}

ChatDB is wrapper above ChatDB

func NewChatDB

func NewChatDB(db db.ChatDB, logged db.LoggedDB, ch chan<- events.Event) *ChatDB

NewChatDB ...

func (*ChatDB) Add

func (d *ChatDB) Add(chatname string) error

Add ...

func (*ChatDB) AddUser

func (d *ChatDB) AddUser(chatname, username string) error

AddUser ...

func (*ChatDB) Remove

func (d *ChatDB) Remove(chatname string) error

Remove ...

func (*ChatDB) RemoveUser

func (d *ChatDB) RemoveUser(chatname, username string) error

RemoveUser ...

func (*ChatDB) StartListeningToEvents

func (d *ChatDB) StartListeningToEvents(ch <-chan events.Event)

StartListeningToEvents starts to listen to events from input channel. Don't call it twice!

type LoggedDB

type LoggedDB struct {
	db.LoggedDB
	// contains filtered or unexported fields
}

LoggedDB ...

func NewLoggedDB

func NewLoggedDB(db db.LoggedDB, ch chan<- events.Event) *LoggedDB

NewLoggedDB ...

func (*LoggedDB) Login

func (d *LoggedDB) Login(username string) (*models.LoggedUser, error)

Login ...

func (*LoggedDB) Logout

func (d *LoggedDB) Logout(username string) error

Logout ...

type MessageDB

type MessageDB struct {
	db.MessageDB
	// contains filtered or unexported fields
}

MessageDB ...

func NewMessageDB

func NewMessageDB(db db.MessageDB, ch chan<- events.Event) *MessageDB

NewMessageDB ...

func (*MessageDB) Post

func (d *MessageDB) Post(msg *models.Message) error

Post ...