stdlib

type AuthProvider interface {
	GetAuthHeader() string
}

type Cache interface {
	Get(key string) (interface{}, error)
	Set(key string, value interface{}) error
	SetWithExpiration(key string, value interface{}, expiration time.Duration) error
	GetCtx(ctx context.Context, key string) (interface{}, error)
	SetCtx(ctx context.Context, key string, value interface{}) error
	SetWithExpirationCtx(ctx context.Context, key string, value interface{}, expiration time.Duration) error
	Delete(key string) error
	DeleteCtx(ctx context.Context, key string) error
	Keys(pattern string) ([]string, error)
	KeysCtx(ctx context.Context, pattern string) ([]string, error)
	WithLogger(l *zap.Logger) Cache
	WithTracer(t *tracer.AppInsightsCore) Cache
	WithName(name string) Cache
}

type Cancel func()

type Client interface {
	Get(ctx Context, baseUrl string, query string, opt *ClientOptions, dest interface{}) (int, error)
	Put(ctx Context, baseUrl string, query string, opt *ClientOptions, body interface{}, dest interface{}) (int, error)
	Del(ctx Context, baseUrl string, query string, opt *ClientOptions, dest interface{}) (int, error)
	Post(ctx Context, baseUrl string, query string, opt *ClientOptions, body interface{}, dest interface{}) (int, error)
	Patch(ctx Context, baseUrl string, query string, opt *ClientOptions, body interface{}, dest interface{}) (int, error)
	// contains filtered or unexported methods
}

type ClientOptions struct {
	Authorization string             `json:"authorization"`
	ContentType   string             `json:"content_type"`
	Query         string             `json:"query"`
	Headers       *map[string]string `json:"headers"`
	Timeout       *time.Time         `json:"timeout"`
	RequestType   string             `json:"request_type"`
	// contains filtered or unexported fields
}

type Context struct {
	context.Context
	Res  chan interface{}
	Code int
	// contains filtered or unexported fields
}

type NativeDatabase interface {
	Begin() (*TracedNativeTx, error)
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*TracedNativeTx, error)
	Close() error
	Conn(ctx context.Context) (*sql.Conn, error)
	Exec(query string, args ...any) (sql.Result, error)
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	Ping() error
	PingContext(ctx context.Context) error
	Prepare(query string) (*sql.Stmt, error)
	PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
	SetConnMaxIdleTime(d time.Duration)
	SetConnMaxLifetime(d time.Duration)
	Stats() sql.DBStats
	WithLogger(l *zap.Logger) NativeDatabase
}

type Pooler[T any] interface {
	Get() *T
	Clear()
	Size() int
}

type PoolingOptions struct {
	PoolSize int
}

type TracedClient interface {
	Get(ctx context.Context, Url string, opt *ClientOptions, dest interface{}) (int, error)
	Put(ctx context.Context, Url string, opt *ClientOptions, body interface{}, dest interface{}) (int, error)
	Del(ctx context.Context, Url string, opt *ClientOptions, dest interface{}) (int, error)
	Post(ctx context.Context, Url string, opt *ClientOptions, body interface{}, dest interface{}) (int, error)
	Patch(ctx context.Context, Url string, opt *ClientOptions, body interface{}, dest interface{}) (int, error)

	SetAuthHandler(provider AuthProvider)
	WithClientName(clientName string) TracedClient
	// contains filtered or unexported methods
}

type TracedNativeTx struct {
	*sql.Tx
	// contains filtered or unexported fields
}