cosmos

Documentation

Index

• Constants
• func DeleteUserData(ctx context.Context, udContainer *azcosmos.ContainerClient, ...) error
• func GetExistingIds(ctx context.Context, container *azcosmos.ContainerClient, ...) (map[string][]string, error)
• func GetListingsQueryItemsPager(container *azcosmos.ContainerClient, city string, query *models.ListingsQuery) *runtime.Pager[azcosmos.QueryItemsResponse]
• func GetNonExistingIds(ctx context.Context, container *azcosmos.ContainerClient, ...) (map[string][]string, error)
• func GetUserData(ctx context.Context, container *azcosmos.ContainerClient, userId string) ([]models.UserData, error)
• func GetUsersMatchingWithListing(ctx context.Context, container *azcosmos.ContainerClient, ...) ([]string, error)
• func InitClients() (client *azcosmos.Client, db *azcosmos.DatabaseClient)
• func InitContainerClient(db *azcosmos.DatabaseClient, containerName string) *azcosmos.ContainerClient

Constants

const DEFAULT_PAGE_SIZE = 10

Functions

func DeleteUserData

func DeleteUserData(
	ctx context.Context,
	udContainer *azcosmos.ContainerClient,
	nsContainer *azcosmos.ContainerClient,
	userId string,
	city string,
) error

func GetExistingIds

func GetExistingIds(ctx context.Context, container *azcosmos.ContainerClient, idsByPk map[string][]string) (map[string][]string, error)

func GetListingsQueryItemsPager

func GetListingsQueryItemsPager(
	container *azcosmos.ContainerClient,
	city string,
	query *models.ListingsQuery,
) *runtime.Pager[azcosmos.QueryItemsResponse]

func GetNonExistingIds

func GetNonExistingIds(ctx context.Context, container *azcosmos.ContainerClient, idsByPk map[string][]string) (map[string][]string, error)

func GetUserData

func GetUserData(ctx context.Context, container *azcosmos.ContainerClient, userId string) ([]models.UserData, error)

func GetUsersMatchingWithListing

func GetUsersMatchingWithListing(ctx context.Context, container *azcosmos.ContainerClient, listing *models.Listing) ([]string, error)

func InitClients

func InitClients() (client *azcosmos.Client, db *azcosmos.DatabaseClient)

func InitContainerClient

func InitContainerClient(db *azcosmos.DatabaseClient, containerName string) *azcosmos.ContainerClient