Documentation ¶
Index ¶
- func NewFactory(gwFactory gateways.Factory) ports.RepositoriesFactory
- func NewLoginRepository(gwFactory gateways.Factory) ports.LoginRepository
- func NewPokerRepository(gwFactory gateways.Factory) ports.PokerRepository
- type PokerRepository
- func (r *PokerRepository) Create(ctx context.Context, loginID string) (room.ID, error)
- func (r *PokerRepository) Delete(ctx context.Context, roomID room.ID) error
- func (r *PokerRepository) Enter(ctx context.Context, roomID room.ID, loginID string) error
- func (r *PokerRepository) IsExistsInRoom(ctx context.Context, roomID room.ID, loginID string) (bool, error)
- func (r *PokerRepository) Leave(ctx context.Context, roomID room.ID, loginID string) error
- func (r *PokerRepository) ListMembers(ctx context.Context, roomID room.ID) ([]string, error)
- func (r *PokerRepository) ReadStream(ctx context.Context, roomID room.ID, messageID string) (string, *porker.PokerSituation, error)
- func (r *PokerRepository) ReadStreamLatest(ctx context.Context, roomID room.ID) (string, *porker.PokerSituation, error)
- func (r *PokerRepository) Update(ctx context.Context, ps *porker.PokerSituation) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFactory ¶
func NewFactory(gwFactory gateways.Factory) ports.RepositoriesFactory
func NewLoginRepository ¶
func NewLoginRepository(gwFactory gateways.Factory) ports.LoginRepository
func NewPokerRepository ¶
func NewPokerRepository(gwFactory gateways.Factory) ports.PokerRepository
Types ¶
type PokerRepository ¶
type PokerRepository struct {
// contains filtered or unexported fields
}
func (*PokerRepository) IsExistsInRoom ¶
func (*PokerRepository) ListMembers ¶
func (*PokerRepository) ReadStream ¶
func (r *PokerRepository) ReadStream(ctx context.Context, roomID room.ID, messageID string) (string, *porker.PokerSituation, error)
func (*PokerRepository) ReadStreamLatest ¶
func (r *PokerRepository) ReadStreamLatest(ctx context.Context, roomID room.ID) (string, *porker.PokerSituation, error)
func (*PokerRepository) Update ¶
func (r *PokerRepository) Update(ctx context.Context, ps *porker.PokerSituation) error
Click to show internal directories.
Click to hide internal directories.