household

Documentation

Index

• type HouseholdRepo
• type HouseholdService
  • func NewHouseholdService(commandBus common.CommandBus, repository UserHouseholdRepo) *HouseholdService
  • func (s HouseholdService) AddRoom(ctx context.Context, data shared.AddRoomCommandData) error
  • func (s HouseholdService) CreateHousehold(ctx context.Context, data shared.CreateHouseholdCommandData) error
  • func (s HouseholdService) DeleteHousehold(ctx context.Context, data shared.DeleteHouseholdCommandData) error
  • func (s HouseholdService) DeleteRoom(ctx context.Context, data shared.DeleteRoomCommandData) error
  • func (s HouseholdService) GetUserHousehold(ctx context.Context, userID, householdID string) (shared.UserHousehold, error)
  • func (s HouseholdService) GetUserHouseholdRoom(ctx context.Context, userID, householdID, roomID string) (shared.UserHouseholdRoom, error)
  • func (s HouseholdService) GetUserHouseholds(ctx context.Context, userID string) ([]shared.UserHousehold, error)
  • func (s HouseholdService) UpdateHousehold(ctx context.Context, data shared.UpdateHouseholdCommandData) error
  • func (s HouseholdService) UpdateRoom(ctx context.Context, data shared.UpdateRoomCommandData) error
• type UserHouseholdModel
• type UserHouseholdProjector
  • func NewUserHouseholdProjector(repository HouseholdRepo) *UserHouseholdProjector
  • func (p UserHouseholdProjector) Events() []es.EventType
  • func (p UserHouseholdProjector) HandleEvent(ctx context.Context, event es.EventData) error
  • func (p UserHouseholdProjector) Name() string
• type UserHouseholdRepo
• type UserHouseholdRepository
  • func NewUserHouseholdRepository(db *gocql.Session) *UserHouseholdRepository
  • func (r UserHouseholdRepository) DeleteHousehold(ctx context.Context, userId string, householdId string) error
  • func (r UserHouseholdRepository) DeleteRoom(ctx context.Context, userId string, householdId string, roomId string) error
  • func (r UserHouseholdRepository) GetRoom(ctx context.Context, userId string, householdId string, roomId string) (UserHouseholdRoomModel, bool, error)
  • func (r UserHouseholdRepository) GetUserHousehold(ctx context.Context, userId string, householdId string) (UserHouseholdModel, bool, error)
  • func (r UserHouseholdRepository) GetUserHouseholds(ctx context.Context, userId string) ([]UserHouseholdModel, error)
  • func (r UserHouseholdRepository) InsertHousehold(ctx context.Context, model UserHouseholdModel) error
  • func (r UserHouseholdRepository) UpdateHousehold(ctx context.Context, model UserHouseholdModel) error
  • func (r UserHouseholdRepository) UpsertRoom(ctx context.Context, userId string, model UserHouseholdRoomModel) error
• type UserHouseholdRoomModel

Types

type HouseholdRepo

type HouseholdRepo interface {
	InsertHousehold(ctx context.Context, model UserHouseholdModel) error
	UpdateHousehold(ctx context.Context, model UserHouseholdModel) error
	DeleteHousehold(ctx context.Context, userId string, householdId string) error

	UpsertRoom(ctx context.Context, userId string, model UserHouseholdRoomModel) error
	DeleteRoom(ctx context.Context, userId string, householdId string, roomId string) error
}

type HouseholdService

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

func NewHouseholdService

func NewHouseholdService(commandBus common.CommandBus, repository UserHouseholdRepo) *HouseholdService

func (HouseholdService) AddRoom

func (s HouseholdService) AddRoom(ctx context.Context, data shared.AddRoomCommandData) error

func (HouseholdService) CreateHousehold

func (s HouseholdService) CreateHousehold(ctx context.Context, data shared.CreateHouseholdCommandData) error

func (HouseholdService) DeleteHousehold

func (s HouseholdService) DeleteHousehold(ctx context.Context, data shared.DeleteHouseholdCommandData) error

func (HouseholdService) DeleteRoom

func (s HouseholdService) DeleteRoom(ctx context.Context, data shared.DeleteRoomCommandData) error

func (HouseholdService) GetUserHousehold

func (s HouseholdService) GetUserHousehold(ctx context.Context, userID, householdID string) (shared.UserHousehold, error)

func (HouseholdService) GetUserHouseholdRoom

func (s HouseholdService) GetUserHouseholdRoom(ctx context.Context, userID, householdID, roomID string) (shared.UserHouseholdRoom, error)

func (HouseholdService) GetUserHouseholds

func (s HouseholdService) GetUserHouseholds(ctx context.Context, userID string) ([]shared.UserHousehold, error)

func (HouseholdService) UpdateHousehold

func (s HouseholdService) UpdateHousehold(ctx context.Context, data shared.UpdateHouseholdCommandData) error

func (HouseholdService) UpdateRoom

func (s HouseholdService) UpdateRoom(ctx context.Context, data shared.UpdateRoomCommandData) error

type UserHouseholdModel

type UserHouseholdModel struct {
	UserID      string
	HouseholdID gocql.UUID
	Name        string
	Location    string
	Description string
	Rooms       []UserHouseholdRoomModel
	Timestamp   int64
	Order       uint
}

type UserHouseholdProjector

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

func NewUserHouseholdProjector

func NewUserHouseholdProjector(repository HouseholdRepo) *UserHouseholdProjector

func (UserHouseholdProjector) Events

func (p UserHouseholdProjector) Events() []es.EventType

func (UserHouseholdProjector) HandleEvent

func (p UserHouseholdProjector) HandleEvent(ctx context.Context, event es.EventData) error

func (UserHouseholdProjector) Name

func (p UserHouseholdProjector) Name() string

type UserHouseholdRepo

type UserHouseholdRepo interface {
	GetUserHouseholds(ctx context.Context, userID string) ([]UserHouseholdModel, error)
	GetUserHousehold(ctx context.Context, userID, householdID string) (UserHouseholdModel, bool, error)
	GetRoom(ctx context.Context, userID, householdID, roomID string) (UserHouseholdRoomModel, bool, error)
}

type UserHouseholdRepository

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

func NewUserHouseholdRepository

func NewUserHouseholdRepository(db *gocql.Session) *UserHouseholdRepository

func (UserHouseholdRepository) DeleteHousehold

func (r UserHouseholdRepository) DeleteHousehold(ctx context.Context, userId string, householdId string) error

func (UserHouseholdRepository) DeleteRoom

func (r UserHouseholdRepository) DeleteRoom(ctx context.Context, userId string, householdId string, roomId string) error

func (UserHouseholdRepository) GetRoom

func (r UserHouseholdRepository) GetRoom(ctx context.Context, userId string, householdId string, roomId string) (UserHouseholdRoomModel, bool, error)

func (UserHouseholdRepository) GetUserHousehold

func (r UserHouseholdRepository) GetUserHousehold(ctx context.Context, userId string, householdId string) (UserHouseholdModel, bool, error)

func (UserHouseholdRepository) GetUserHouseholds

func (r UserHouseholdRepository) GetUserHouseholds(ctx context.Context, userId string) ([]UserHouseholdModel, error)

func (UserHouseholdRepository) InsertHousehold

func (r UserHouseholdRepository) InsertHousehold(ctx context.Context, model UserHouseholdModel) error

func (UserHouseholdRepository) UpdateHousehold

func (r UserHouseholdRepository) UpdateHousehold(ctx context.Context, model UserHouseholdModel) error

func (UserHouseholdRepository) UpsertRoom

func (r UserHouseholdRepository) UpsertRoom(ctx context.Context, userId string, model UserHouseholdRoomModel) error

type UserHouseholdRoomModel

type UserHouseholdRoomModel struct {
	HouseholdID gocql.UUID `cql:"household_id"`
	RoomID      gocql.UUID `cql:"room_id"`
	Name        string     `cql:"name"`
	Order       uint       `cql:"sort_order"`
	Timestamp   int64      `cql:"tstamp"`
}