db

Documentation

Index

• Variables
• type DB
  • func NewConnection() (DB, error)
• type DBTx
• type Message

Variables

var (
	ErrMessageAlreadyExists = errors.New("message already exists")
)

Types

type DB

type DB interface {
	Close()
	StartTransaction() (DBTx, error)
}

func NewConnection

func NewConnection() (DB, error)

type DBTx

type DBTx interface {
	Commit() error
	Rollback() error
	//Message
	CreateMessage(message *Message) error
	GetMessages(lobbyId uuid.UUID, toIgnoreplayerId uuid.UUID, number int) ([]*Message, error)
	GetMessagesFirstRequest(lobbyId uuid.UUID, toIgnoreplayerId uuid.UUID) ([]*Message, error)
	DeleteMessages(time time.Time) error
}

type Message

type Message struct {
	ID       uuid.UUID              `db:"id"`
	SendTime time.Time              `db:"send_time"`
	LobbyId  uuid.UUID              `db:"lobby_id"`
	PlayerId uuid.UUID              `db:"player_id"`
	Number   int                    `db:"number"`
	Topic    string                 `db:"topic"`
	Message  map[string]interface{} `db:"message"`
}