repository

Documentation

Index

• type CachePort
• type MqPort
• type PersistencePort

Types

type CachePort

type CachePort interface {
	SetCartCache(ctx context.Context, key string, cart string) error
	GetCartCache(ctx context.Context, key string) (string, error)
	IsKeyExist(ctx context.Context, key string) bool
}

type MqPort

type MqPort interface {
	SendAddGoods(ctx context.Context, uid int64, goods *model.GoodInfo) error
	ConsumeAddGoods(ctx context.Context) <-chan *kafka.Message
}

type PersistencePort

type PersistencePort interface {
	CreateCart(ctx context.Context, uid int64, cart string) error
	GetCartByUserId(ctx context.Context, uid int64) (bool, *model.Cart, error)
	SaveCart(ctx context.Context, uid int64, cart string) error
}