utils

package

Go to main page

Versions in this module

v0

v0.0.15

Aug 24, 2025

Changes in this version

+ var GlobalPostgreSQLTypeConverter = NewPostgreSQLTypeConverter()

type CDCMessage

+ CopyData [][]byte

+ type ColumnNotFoundError struct

+ ColumnName string

+ func (e ColumnNotFoundError) Error() string

+ type PostgreSQLTypeConverter struct

+ func NewPostgreSQLTypeConverter() *PostgreSQLTypeConverter

+ func (c *PostgreSQLTypeConverter) DecodePostgreSQLValue(data []byte, dataTypeOID uint32, format int16) (interface{}, error)

+ func (c *PostgreSQLTypeConverter) EncodePostgreSQLValue(value interface{}, dataTypeOID uint32) ([]byte, error)

v0.0.14

Aug 14, 2025

Changes in this version

type CDCMessage

+ func (m *CDCMessage) RemoveColumn(columnName string) error

v0.0.13

Feb 6, 2025

v0.0.12

Nov 19, 2024

Changes in this version

+ type LogEvent interface

+ Any func(key string, val interface{}) LogEvent

+ Err func(err error) LogEvent

+ Int func(key string, val int) LogEvent

+ Int64 func(key string, val int64) LogEvent

+ Interface func(key string, val interface{}) LogEvent

+ Msg func(msg string)

+ Msgf func(format string, v ...interface{})

+ Str func(key, val string) LogEvent

+ Strs func(key string, vals []string) LogEvent

+ Type func(key string, val interface{}) LogEvent

+ Uint32 func(key string, val uint32) LogEvent

+ Uint8 func(key string, val uint8) LogEvent

+ type Logger interface

+ Debug func() LogEvent

+ Err func(err error) LogEvent

+ Error func() LogEvent

+ Info func() LogEvent

+ Warn func() LogEvent

+ func NewZerologLogger(logger zerolog.Logger) Logger

+ type ZerologLogEvent struct

+ func (e *ZerologLogEvent) Any(key string, val interface{}) LogEvent

+ func (e *ZerologLogEvent) Err(err error) LogEvent

+ func (e *ZerologLogEvent) Int(key string, val int) LogEvent

+ func (e *ZerologLogEvent) Int64(key string, val int64) LogEvent

+ func (e *ZerologLogEvent) Interface(key string, val interface{}) LogEvent

+ func (e *ZerologLogEvent) Msg(msg string)

+ func (e *ZerologLogEvent) Msgf(format string, v ...interface{})

+ func (e *ZerologLogEvent) Str(key, val string) LogEvent

+ func (e *ZerologLogEvent) Strs(key string, vals []string) LogEvent

+ func (e *ZerologLogEvent) Type(key string, val interface{}) LogEvent

+ func (e *ZerologLogEvent) Uint32(key string, val uint32) LogEvent

+ func (e *ZerologLogEvent) Uint8(key string, val uint8) LogEvent

+ type ZerologLogger struct

+ func (z *ZerologLogger) Debug() LogEvent

+ func (z *ZerologLogger) Err(err error) LogEvent

+ func (z *ZerologLogger) Error() LogEvent

+ func (z *ZerologLogger) Info() LogEvent

+ func (z *ZerologLogger) Warn() LogEvent

v0.0.11

Nov 16, 2024

Changes in this version

+ var OidToTypeName = map[uint32]string

+ func ConvertToPgCompatibleOutput(value interface{}, oid uint32) ([]byte, error)

+ func DecodeArray(data []byte, dataType uint32) (interface{}, error)

+ func DecodeTextArray(data []byte) ([]string, error)

+ func DecodeValue(data []byte, dataType uint32) (interface{}, error)

+ func EncodeArray(value interface{}) ([]byte, error)

+ func EncodeCDCMessage(m CDCMessage) ([]byte, error)

+ func EncodeValue(value interface{}, dataType uint32) ([]byte, error)

+ func OIDToString(oid uint32) string

+ func ParseTimestamp(value string) (time.Time, error)

+ func StringToOID(typeName string) uint32

+ func ToBool(v interface{}) (bool, bool)

+ func ToFloat64(v interface{}) (float64, bool)

+ func ToInt64(v interface{}) (int64, bool)

+ func WithRetry(ctx context.Context, cfg RetryConfig, operation func() error) error

+ type CDCMessage struct

+ Columns []*pglogrepl.RelationMessageColumn

+ EmittedAt time.Time

+ LSN string

+ NewTuple *pglogrepl.TupleData

+ OldTuple *pglogrepl.TupleData

+ ReplicationKey ReplicationKey

+ Schema string

+ Table string

+ ToastedColumns map[string]bool

+ Type OperationType

+ func DecodeCDCMessage(data []byte) (*CDCMessage, error)

+ func (m *CDCMessage) GetColumnIndex(columnName string) int

+ func (m *CDCMessage) GetColumnValue(columnName string, useOldValues bool) (interface{}, error)

+ func (m *CDCMessage) IsColumnToasted(columnName string) bool

+ func (m *CDCMessage) SetColumnValue(columnName string, value interface{}) error

+ func (m *CDCMessage) UnmarshalBinary(data []byte) error

+ func (m CDCMessage) MarshalBinary() ([]byte, error)

+ type OperationType string

+ const OperationDDL

+ const OperationDelete

+ const OperationInsert

+ const OperationUpdate

+ type ReplicationKey struct

+ Columns []string

+ Type ReplicationKeyType

+ func (rk *ReplicationKey) IsValid() bool

+ type ReplicationKeyType string

+ const ReplicationKeyFull

+ const ReplicationKeyPK

+ const ReplicationKeyUnique

+ type RetryConfig struct

+ InitialWait time.Duration

+ MaxAttempts int

+ MaxWait time.Duration

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL