database

Documentation

Index

• Constants
• type DB
  • func New(config aws.Config) *DB
  • func (db *DB) AppendRoomToConnections(cs []connection.Connection, room room.Room) error
  • func (db *DB) EditMessage(editRequest request.EditRequest) (message.Message, error)
  • func (db *DB) GetConnection(cid string) (connection.Connection, error)
  • func (db *DB) GetConnectionsByRoom(rid string) ([]connectionroomitem.ConnectionRoomItem, error)
  • func (db *DB) GetConnectionsByUserId(uid string) ([]connection.Connection, error)
  • func (db *DB) GetMessagesAfter(mid, uid string) (*[]message.Message, error)
  • func (db *DB) GetRoomHeader(id string) optional.Optional[room.Room]
  • func (db *DB) ReactToMessage(mid string, reaction reaction.Reaction) (message.Message, error)
  • func (db *DB) RemoveConnection(cid string) error
  • func (db *DB) SaveConnection(c connection.Connection) error
  • func (db *DB) SaveMessage(message message.Message) error
  • func (db *DB) SaveRoom(room room.Room) error

Constants

const BATCH_SIZE = 25

Types

type DB

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

func New

func New(config aws.Config) *DB

func (*DB) AppendRoomToConnections

func (db *DB) AppendRoomToConnections(cs []connection.Connection, room room.Room) error

func (*DB) EditMessage

func (db *DB) EditMessage(editRequest request.EditRequest) (message.Message, error)

func (*DB) GetConnection

func (db *DB) GetConnection(cid string) (connection.Connection, error)

func (*DB) GetConnectionsByRoom

func (db *DB) GetConnectionsByRoom(rid string) ([]connectionroomitem.ConnectionRoomItem, error)

func (*DB) GetConnectionsByUserId

func (db *DB) GetConnectionsByUserId(uid string) ([]connection.Connection, error)

func (*DB) GetMessagesAfter

func (db *DB) GetMessagesAfter(mid, uid string) (*[]message.Message, error)

func (*DB) GetRoomHeader

func (db *DB) GetRoomHeader(id string) optional.Optional[room.Room]

func (*DB) ReactToMessage

func (db *DB) ReactToMessage(mid string, reaction reaction.Reaction) (message.Message, error)

func (*DB) RemoveConnection

func (db *DB) RemoveConnection(cid string) error

func (*DB) SaveConnection

func (db *DB) SaveConnection(c connection.Connection) error

func (*DB) SaveMessage

func (db *DB) SaveMessage(message message.Message) error

func (*DB) SaveRoom

func (db *DB) SaveRoom(room room.Room) error