repository

Documentation

Index

• func New(address string) *roomsRepository
• type RoomsRepository

Functions

func New

func New(address string) *roomsRepository

Types

type RoomsRepository

type RoomsRepository interface {
	/*
	   events.go functions
	*/
	PublishEvent(ctx context.Context, event model.Event) error
	SubscribeToEvents(ctx context.Context, eventHandler func(event model.Event)) error

	/*
	   rooms.go functions
	*/
	InsertRoom(ctx context.Context, room *model.Room) error
	UpdateRoom(ctx context.Context, id string, name string, hostId string, maxPlayers uint32, questionCount uint32, status model.RoomStatus) error
	UpdateRoomStatus(ctx context.Context, id string, status model.RoomStatus) error
	GetRoomById(ctx context.Context, id string) (*model.Room, error)

	/*
	   users.go functions
	*/
	InsertUserInRoom(ctx context.Context, userId string, roomId string) error
	RemoveUserFromRoom(ctx context.Context, userId string, roomId string) error
	GetRoomPlayersCount(ctx context.Context, id string) (uint32, error)

	/*
	   questions.go functions
	*/
	GetQuestionCount(ctx context.Context, roomId string) (int, error)
}