adapters

Documentation

Index

• Variables
• func CachePolicyByQty(target int) func(current int) bool
• func ConvertErrorFromHttpClient(err error) error
• func ConvertErrorFromRedis(err error) error
• func GetHttpJsonBodyByType[T any](client *http.Client, logger *slog.Logger, ctx context.Context, endpoint string) (view T, Err error)
• func GetLocalCacheByType[T any](store *bigcache.BigCache, key string) (val T, Err error)
• func GetRedisStringByType[T any](client *redis.Client, unmarshal utility.Unmarshal, logger *slog.Logger, ...) (resp T, Err error)
• func HandleErrorByFiber(c *fiber.Ctx, err error) error
• func NewHttpClient() *http.Client
• func NewLocalCache() (*bigcache.BigCache, error)
• func NewMessageConsumer()
• func NewMessageProducer()
• func NewMySqlGorm(conf *pkg.MySql) (*gorm.DB, error)
• func NewRedis(conf *pkg.Redis) (*redis.Client, error)
• func ParseJsonBody(c *fiber.Ctx, req any, logger *slog.Logger) error
• func ParseQueryString(c *fiber.Ctx, req any, logger *slog.Logger) error
• func SetLocalCacheByType[T any](store *bigcache.BigCache, key string, val *T) (Err error)
• type ErrorResponse
  • func NewErrorResponse(code int, message string) *ErrorResponse

Variables

var FiberMetadata = newFiberMetadataKey()

var FiberO11YMetric = wfiber.NewO11YMetric(pkg.Version().ServiceName)

Functions

func CachePolicyByQty

func CachePolicyByQty(target int) func(current int) bool

CachePolicyByQty This is used in scenarios involving count accumulation to decide when to use local cache.

When current value is too far from target value, local cache is used to reduce database load. If current value is close to target value, local cache is bypassed.

Return bool:

true  - Use local cache (current value is far from the target).
false - Bypass local cache (current value is close to the target).

func ConvertErrorFromHttpClient

func ConvertErrorFromHttpClient(err error) error

ConvertErrorFromHttpClient 還不知道會有怎樣的 http error, 所以只先定義預設錯誤

func ConvertErrorFromRedis

func ConvertErrorFromRedis(err error) error

func GetHttpJsonBodyByType

func GetHttpJsonBodyByType[T any](

	client *http.Client,
	logger *slog.Logger,

	ctx context.Context,
	endpoint string,
) (view T, Err error)

func GetLocalCacheByType

func GetLocalCacheByType[T any](store *bigcache.BigCache, key string) (val T, Err error)

func GetRedisStringByType

func GetRedisStringByType[T any](

	client *redis.Client,
	unmarshal utility.Unmarshal,
	logger *slog.Logger,

	ctx context.Context,
	key string,
) (resp T, Err error)

func HandleErrorByFiber

func HandleErrorByFiber(c *fiber.Ctx, err error) error

func NewHttpClient

func NewHttpClient() *http.Client

func NewLocalCache

func NewLocalCache() (*bigcache.BigCache, error)

func NewMessageConsumer

func NewMessageConsumer()

func NewMessageProducer

func NewMessageProducer()

func NewMySqlGorm

func NewMySqlGorm(conf *pkg.MySql) (*gorm.DB, error)

func NewRedis

func NewRedis(conf *pkg.Redis) (*redis.Client, error)

func ParseJsonBody

func ParseJsonBody(c *fiber.Ctx, req any, logger *slog.Logger) error

func ParseQueryString

func ParseQueryString(c *fiber.Ctx, req any, logger *slog.Logger) error

func SetLocalCacheByType

func SetLocalCacheByType[T any](store *bigcache.BigCache, key string, val *T) (Err error)

Types

type ErrorResponse

type ErrorResponse struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

func NewErrorResponse

func NewErrorResponse(code int, message string) *ErrorResponse