stdlib

Jan 3, 2023

Changes in this version

type TracedClient

+ Close func()

+ WithStandardTransport func() TracedClient

+ WithTransport func(transport http.Transport) TracedClient

Dec 17, 2022

Changes in this version

+ func EmbedNamedPositionArgs(stringObject string, args ...string) string

type Client

+ Invoke func(ctx context.Context, method string, url string, opt *ClientOptions, ...) (int, error)

+ WithTracer func(t *appinsightstrace.AppInsightsCore) Client

type ClientOptions

+ PositionalArgs []string

type TracedClient

+ Invoke func(ctx context.Context, method string, url string, opt *ClientOptions, ...) (int, error)

Dec 13, 2022

Changes in this version

type Client

+ SetAuthHandler func(provider AuthProvider)

+ WithLogger func(l *zap.Logger) Client

+ type Pooler interface

+ Clear func()

+ Get func() *T

+ Size func() int

+ func NewPool(initFunction func() *T, opt *PoolingOptions) (Pooler[T], error)

+ type PoolingOptions struct

+ PoolSize int

type TracedClient

+ WithClientName func(clientName string) TracedClient

Nov 23, 2022

Changes in this version

+ const FLAG_INVALID_LENGTH

+ const INVALID_VALUE_COUNT

+ const MEMORY_CACHE_TYPE

+ const PARENTID_INVALID_LENGTH

+ const PARENTID_IS_ZERO

+ const REDIS_CACHE_TYPE

+ const TRACEID_INVALID_LENGTH

+ const TRACEID_IS_ZERO

+ const VERSION_INVALID_LENGTH

+ var Err_KEY_NOT_FOUND = fmt.Errorf("key not found")

+ func ConsoleLogger(args ...string) *zap.SugaredLogger

+ func GenerateNewTraceparent(sampled bool) (string, error)

+ func GenerateParentId() (string, error)

+ func GenerateParentIdRaw() ([]byte, error)

+ func GenerateRandomBytes(n int) ([]byte, error)

+ func GenerateTraceId() (string, error)

+ func GenerateTraceIdRaw() ([]byte, error)

+ func NewContextWithCancel() (Context, Cancel)

+ func NewContextWithDeadline(deadline time.Time) (Context, Cancel)

+ func ParseTraceparent(traceparent string) (string, string, string, string, error)

+ func ParseTraceparentRaw(traceparent string) ([]byte, []byte, []byte, []byte, error)

+ func ValidateParentIdValue(parentId []byte) error

+ func ValidateTraceIdValue(traceId []byte) error

+ type AuthProvider interface

+ GetAuthHeader func() string

+ type Cache interface

+ Delete func(key string) error

+ DeleteCtx func(ctx context.Context, key string) error

+ Get func(key string) (interface{}, error)

+ GetCtx func(ctx context.Context, key string) (interface{}, error)

+ Keys func(pattern string) ([]string, error)

+ KeysCtx func(ctx context.Context, pattern string) ([]string, error)

+ Set func(key string, value interface{}) error

+ SetCtx func(ctx context.Context, key string, value interface{}) error

+ SetWithExpiration func(key string, value interface{}, expiration time.Duration) error

+ SetWithExpirationCtx func(ctx context.Context, key string, value interface{}, expiration time.Duration) error

+ WithLogger func(l *zap.Logger) Cache

+ WithName func(name string) Cache

+ WithTracer func(t *tracer.AppInsightsCore) Cache

+ func CreateFailedMockCacher() Cache

+ func CreateSuccessMockCacher() Cache

+ func InitMemoryCache(expiration time.Duration, cleanupInterval time.Duration) Cache

+ func InitRedisCache(url string) (Cache, error)

+ type Cancel func()

+ type Client interface

+ Del func(ctx Context, baseUrl string, query string, opt *ClientOptions, ...) (int, error)

+ Get func(ctx Context, baseUrl string, query string, opt *ClientOptions, ...) (int, error)

+ Patch func(ctx Context, baseUrl string, query string, opt *ClientOptions, ...) (int, error)

+ Post func(ctx Context, baseUrl string, query string, opt *ClientOptions, ...) (int, error)

+ Put func(ctx Context, baseUrl string, query string, opt *ClientOptions, ...) (int, error)

+ func ClientProvider() Client

+ type ClientOptions struct

+ Authorization string

+ ContentType string

+ Headers *map[string]string

+ Query string

+ RequestType string

+ Timeout *time.Time

+ type Context struct

+ Code int

+ Res chan interface{}

+ func NewContext() Context

+ func WrapContext(ctx context.Context) Context

+ func (c *Context) Deadline() (deadline time.Time, ok bool)

+ func (c *Context) Error() error

+ func (c *Context) OnCancel() <-chan struct{}

+ func (r *Context) AddDeadline(deadline time.Time) Cancel

+ func (r *Context) Cancel()

+ func (r *Context) CompletionHandler(code int, result interface{})

+ func (r *Context) Value(key string) interface{}

+ func (r *Context) WithValue(key, val interface{})

+ type NativeDatabase interface

+ Begin func() (*TracedNativeTx, error)

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*TracedNativeTx, error)

+ Close func() error

+ Conn func(ctx context.Context) (*sql.Conn, error)

+ Exec func(query string, args ...any) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ Ping func() error

+ PingContext func(ctx context.Context) error

+ Prepare func(query string) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ Query func(query string, args ...any) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRow func(query string, args ...any) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ SetConnMaxIdleTime func(d time.Duration)

+ SetConnMaxLifetime func(d time.Duration)

+ Stats func() sql.DBStats

+ WithLogger func(l *zap.Logger) NativeDatabase

+ func NativeDatabaseProvider(Driver string, DSN string) NativeDatabase

+ func TracedNativeDBWrapper(Driver string, DSN string, t *tracer.AppInsightsCore, name string) NativeDatabase

+ type TracedClient interface

+ Del func(ctx context.Context, Url string, opt *ClientOptions, dest interface{}) (int, error)

+ Get func(ctx context.Context, Url string, opt *ClientOptions, dest interface{}) (int, error)

+ Patch func(ctx context.Context, Url string, opt *ClientOptions, body interface{}, ...) (int, error)

+ Post func(ctx context.Context, Url string, opt *ClientOptions, body interface{}, ...) (int, error)

+ Put func(ctx context.Context, Url string, opt *ClientOptions, body interface{}, ...) (int, error)

+ SetAuthHandler func(provider AuthProvider)

+ func TracedClientProvider(t *tracer.AppInsightsCore, l *zap.Logger) TracedClient

+ func TracedClientProviderWithName(t *tracer.AppInsightsCore, l *zap.Logger, clientName string) TracedClient

+ type TracedNativeTx struct

+ func (t *TracedNativeTx) Commit() error

+ func (t *TracedNativeTx) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (t *TracedNativeTx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (t *TracedNativeTx) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (t *TracedNativeTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (t *TracedNativeTx) QueryRow(query string, args ...interface{}) *sql.Row

+ func (t *TracedNativeTx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (t *TracedNativeTx) Rollback() error