infrastructure

package
v0.0.0-...-5038352 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 25, 2022 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BIGINT_Int0  = bignum.Int0()
	BIGINT_Int10 = bignum.Int10()
)
View Source 
var PostgresStmtBuilder = sq.StatementBuilder.PlaceholderFormat(sq.Dollar)

Functions

func NewPgxConn 

func NewPgxConn(config PgxConnConfig, logger usecase.Logger) (*pgx.Conn, error)

func NewPgxConnPool 

func NewPgxConnPool(config PgxConnPoolConfig, logger usecase.Logger) (*pgxpool.Pool, error)

Types

type PgxConnConfig 

type PgxConnConfig struct {
	Host     string
	Port     uint32
	Username string
	Password string
	Database string
	SSL      bool
}

func (*PgxConnConfig) ToURL 

func (config *PgxConnConfig) ToURL() string

type PgxConnLike 

type PgxConnLike interface {
	Begin(ctx context.Context) (pgx.Tx, error)
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
	Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
	QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
	Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
}

type PgxConnPoolConfig 

type PgxConnPoolConfig struct {
	PgxConnConfig     `url:"-"`
	MaxConns          int32         `url:"pool_max_conns"`
	MinConns          int32         `url:"pool_min_conns"`
	MaxConnLifeTime   time.Duration `url:"pool_max_conn_lifetime"`
	MaxConnIdleTime   time.Duration `url:"pool_max_conn_idle_time"`
	HealthCheckPeriod time.Duration `url:"pool_health_check_period"`
}

func (*PgxConnPoolConfig) ToURL 

func (config *PgxConnPoolConfig) ToURL() string

type PgxLoggerAdapter 

type PgxLoggerAdapter struct {
	// contains filtered or unexported fields
}

func NewPgxLoggerAdapter 

func NewPgxLoggerAdapter(logger usecase.Logger) *PgxLoggerAdapter

func (*PgxLoggerAdapter) Log 

func (logger *PgxLoggerAdapter) Log(ctx context.Context, level pgx.LogLevel, msg string, data map[string]interface{})

type PgxRDbConn 

type PgxRDbConn struct {
	// contains filtered or unexported fields
}

func NewPgxRDbConn 

func NewPgxRDbConn(pgxConn PgxConnLike) *PgxRDbConn

func (*PgxRDbConn) Begin 

func (conn *PgxRDbConn) Begin() (adapter.RDbTx, error)

func (*PgxRDbConn) Exec 

func (conn *PgxRDbConn) Exec(sql string, args ...interface{}) (adapter.RDbExecResult, error)

func (*PgxRDbConn) Query 

func (conn *PgxRDbConn) Query(sql string, args ...interface{}) (adapter.RDbRowsResult, error)

func (*PgxRDbConn) QueryRow 

func (conn *PgxRDbConn) QueryRow(sql string, args ...interface{}) adapter.RDbRowResult

type PgxRDbExecResult 

type PgxRDbExecResult struct {
	// contains filtered or unexported fields
}

func (*PgxRDbExecResult) IsDelete 

func (result *PgxRDbExecResult) IsDelete() bool

func (*PgxRDbExecResult) IsInsert 

func (result *PgxRDbExecResult) IsInsert() bool

func (*PgxRDbExecResult) IsSelect 

func (result *PgxRDbExecResult) IsSelect() bool

func (*PgxRDbExecResult) IsUpdate 

func (result *PgxRDbExecResult) IsUpdate() bool

func (*PgxRDbExecResult) RowsAffected 

func (result *PgxRDbExecResult) RowsAffected() int64

func (*PgxRDbExecResult) String 

func (result *PgxRDbExecResult) String() string

type PgxRDbNtobReader 

type PgxRDbNtobReader struct {
	// contains filtered or unexported fields
}

func (*PgxRDbNtobReader) Parse 

func (reader *PgxRDbNtobReader) Parse() (*big.Int, error)

func (*PgxRDbNtobReader) ParseW 

func (reader *PgxRDbNtobReader) ParseW() (*bignum.WBigInt, error)

func (*PgxRDbNtobReader) ScannableArg 

func (reader *PgxRDbNtobReader) ScannableArg() interface{}

type PgxRDbNtotReader 

type PgxRDbNtotReader struct {
	// contains filtered or unexported fields
}

func NewPgxRDbNtotReader 

func NewPgxRDbNtotReader() *PgxRDbNtotReader

func (*PgxRDbNtotReader) Parse 

func (reader *PgxRDbNtotReader) Parse() (*time.Time, error)

func (*PgxRDbNtotReader) ScannableArg 

func (reader *PgxRDbNtotReader) ScannableArg() interface{}

type PgxRDbRowResult 

type PgxRDbRowResult struct {
	// contains filtered or unexported fields
}

func (*PgxRDbRowResult) Scan 

func (result *PgxRDbRowResult) Scan(dest ...interface{}) error

type PgxRDbRowsResult 

type PgxRDbRowsResult struct {
	// contains filtered or unexported fields
}

func (*PgxRDbRowsResult) Close 

func (result *PgxRDbRowsResult) Close()

func (*PgxRDbRowsResult) Err 

func (result *PgxRDbRowsResult) Err() error

func (*PgxRDbRowsResult) ExecResult 

func (result *PgxRDbRowsResult) ExecResult() adapter.RDbExecResult

func (*PgxRDbRowsResult) Next 

func (result *PgxRDbRowsResult) Next() bool

func (*PgxRDbRowsResult) Scan 

func (result *PgxRDbRowsResult) Scan(dest ...interface{}) error

type PgxRDbTx 

type PgxRDbTx struct {
	// contains filtered or unexported fields
}

func (*PgxRDbTx) Commit 

func (tx *PgxRDbTx) Commit() error

func (*PgxRDbTx) Exec 

func (tx *PgxRDbTx) Exec(sql string, args ...interface{}) (adapter.RDbExecResult, error)

func (*PgxRDbTx) Query 

func (tx *PgxRDbTx) Query(sql string, args ...interface{}) (adapter.RDbRowsResult, error)

func (*PgxRDbTx) QueryRow 

func (tx *PgxRDbTx) QueryRow(sql string, args ...interface{}) adapter.RDbRowResult

func (*PgxRDbTx) Rollback 

func (tx *PgxRDbTx) Rollback() error

type PgxRDbTypeConv 

type PgxRDbTypeConv struct{}

func (*PgxRDbTypeConv) Bton 

func (conv *PgxRDbTypeConv) Bton(b *big.Int) interface{}

func (*PgxRDbTypeConv) Iton 

func (conv *PgxRDbTypeConv) Iton(i int) interface{}

func (*PgxRDbTypeConv) NtobReader 

func (conv *PgxRDbTypeConv) NtobReader() adapter.RDbNtobReader

func (*PgxRDbTypeConv) NtotReader 

func (conv *PgxRDbTypeConv) NtotReader() adapter.RDbNtotReader

func (*PgxRDbTypeConv) Tton 

func (conv *PgxRDbTypeConv) Tton(t *time.Time) interface{}

type ZerologLogger 

type ZerologLogger struct {
	// contains filtered or unexported fields
}

func NewZerologLogger 

func NewZerologLogger(output io.Writer) *ZerologLogger

func NewZerologLoggerWithColor 

func NewZerologLoggerWithColor(output io.Writer) *ZerologLogger

func (*ZerologLogger) Debug 

func (logger *ZerologLogger) Debug(message string)

func (*ZerologLogger) Debugf 

func (logger *ZerologLogger) Debugf(format string, values ...interface{})

func (*ZerologLogger) Error 

func (logger *ZerologLogger) Error(message string)

func (*ZerologLogger) Errorf 

func (logger *ZerologLogger) Errorf(format string, values ...interface{})

func (*ZerologLogger) GetLogLevel 

func (logger *ZerologLogger) GetLogLevel() usecase.LogLevel

func (*ZerologLogger) Info 

func (logger *ZerologLogger) Info(message string)

func (*ZerologLogger) Infof 

func (logger *ZerologLogger) Infof(format string, values ...interface{})

func (*ZerologLogger) Panic 

func (logger *ZerologLogger) Panic(message string)

func (*ZerologLogger) Panicf 

func (logger *ZerologLogger) Panicf(format string, values ...interface{})

func (*ZerologLogger) SetLogLevel 

func (logger *ZerologLogger) SetLogLevel(level usecase.LogLevel)

func (*ZerologLogger) WithFields 

func (logger *ZerologLogger) WithFields(fields usecase.LogFields) usecase.Logger

func (*ZerologLogger) WithInterface 

func (logger *ZerologLogger) WithInterface(key string, value interface{}) usecase.Logger

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.