postgresparser

package

v2.0.0-alpha56 Latest Latest Go to latest Published: Jan 3, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/charankamarapu/keploy

README ¶

Integrations Package Documentation

This package includes modules that are used for parsing different protocols.

Documentation ¶

Index ¶

Constants
Variables
func CheckValidEncode(tcsMocks []*models.Mock, h *hooks.Hook, log *zap.Logger)
func PostgresDecoder(encoded string) ([]byte, error)
func PostgresDecoderBackend(request models.Backend) ([]byte, error)
func PostgresDecoderFrontend(response models.Frontend) ([]byte, error)
func PostgresEncoder(buffer []byte) string
func ReadBuffConn(conn net.Conn, bufferChannel chan []byte, errChannel chan error, ...) error
type BackendWrapper
- func NewBackend() *BackendWrapper
- func (b *BackendWrapper) DecodeStartupMessage(buf []byte) (pgproto3.FrontendMessage, error)
- func (b *BackendWrapper) TranslateToReadableBackend(msgBody []byte) (pgproto3.FrontendMessage, error)
type FrontendWrapper
- func NewFrontend() *FrontendWrapper
- func (f *FrontendWrapper) TranslateToReadableResponse(msgBody []byte, logger *zap.Logger) (pgproto3.BackendMessage, error)
type PostgresParser
- func NewPostgresParser(logger *zap.Logger, h *hooks.Hook) *PostgresParser
- func (p *PostgresParser) OutgoingType(buffer []byte) bool
- func (p *PostgresParser) ProcessOutgoing(requestBuffer []byte, clientConn, destConn net.Conn, ctx context.Context)

Constants ¶

View Source

const (
	AuthTypeOk                = 0
	AuthTypeCleartextPassword = 3
	AuthTypeMD5Password       = 5
	AuthTypeSCMCreds          = 6
	AuthTypeGSS               = 7
	AuthTypeGSSCont           = 8
	AuthTypeSSPI              = 9
	AuthTypeSASL              = 10
	AuthTypeSASLContinue      = 11
	AuthTypeSASLFinal         = 12
)

View Source

const ProtocolVersionNumber uint32 = 196608 // Replace with actual version number if different

Variables ¶

View Source

var Emoji = "\U0001F430" + " Keploy:"

Functions ¶

func CheckValidEncode ¶

func CheckValidEncode(tcsMocks []*models.Mock, h *hooks.Hook, log *zap.Logger)

func PostgresDecoder ¶

func PostgresDecoder(encoded string) ([]byte, error)

func PostgresDecoderBackend ¶

func PostgresDecoderBackend(request models.Backend) ([]byte, error)

func PostgresDecoderFrontend ¶

func PostgresDecoderFrontend(response models.Frontend) ([]byte, error)

func PostgresEncoder ¶

func PostgresEncoder(buffer []byte) string

func ReadBuffConn ¶

func ReadBuffConn(conn net.Conn, bufferChannel chan []byte, errChannel chan error, logger *zap.Logger, h *hooks.Hook) error

Types ¶

type BackendWrapper ¶

type BackendWrapper struct {
	BackendWrapper models.Backend
}

func NewBackend ¶

func NewBackend() *BackendWrapper

func (*BackendWrapper) DecodeStartupMessage ¶

func (b *BackendWrapper) DecodeStartupMessage(buf []byte) (pgproto3.FrontendMessage, error)

func (*BackendWrapper) TranslateToReadableBackend ¶

func (b *BackendWrapper) TranslateToReadableBackend(msgBody []byte) (pgproto3.FrontendMessage, error)

PG Response Packet Transcoder

type FrontendWrapper ¶

type FrontendWrapper struct {
	FrontendWrapper models.Frontend
}

func NewFrontend ¶

func NewFrontend() *FrontendWrapper

func (*FrontendWrapper) TranslateToReadableResponse ¶

func (f *FrontendWrapper) TranslateToReadableResponse(msgBody []byte, logger *zap.Logger) (pgproto3.BackendMessage, error)

type PostgresParser ¶

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

func NewPostgresParser ¶

func NewPostgresParser(logger *zap.Logger, h *hooks.Hook) *PostgresParser

func (*PostgresParser) OutgoingType ¶

func (p *PostgresParser) OutgoingType(buffer []byte) bool

func (*PostgresParser) ProcessOutgoing ¶

func (p *PostgresParser) ProcessOutgoing(requestBuffer []byte, clientConn, destConn net.Conn, ctx context.Context)

Source Files ¶

View all Source files

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