postgres

package
v0.6.5 Latest Latest
Warning

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

Go to latest
Published: Nov 16, 2023 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPostgres

func NewPostgres(logger logger.Logger) bindings.OutputBinding

NewPostgres returns a new PostgreSQL output binding.

Types

type PostgresOperations

type PostgresOperations struct {
	BaseOperations
	// contains filtered or unexported fields
}

PostgresOperations represents PostgreSQL output binding.

func (*PostgresOperations) CheckStatusOps

func (pgOps *PostgresOperations) CheckStatusOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

func (*PostgresOperations) ExecOps

func (pgOps *PostgresOperations) ExecOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

func (*PostgresOperations) GetLogger

func (pgOps *PostgresOperations) GetLogger() logger.Logger

GetLogger is used for getting logger, implements BaseInternalOps interface

func (*PostgresOperations) GetRole

func (pgOps *PostgresOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, response *bindings.InvokeResponse) (string, error)

func (*PostgresOperations) GetRunningPort

func (pgOps *PostgresOperations) GetRunningPort() int

func (*PostgresOperations) Init

func (pgOps *PostgresOperations) Init(metadata bindings.Metadata) error

Init initializes the PostgreSql binding.

func (*PostgresOperations) InternalExec

func (pgOps *PostgresOperations) InternalExec(ctx context.Context, sql string) (result int64, err error)

InternalExec is used for internal execution, implements BaseInternalOps interface

func (*PostgresOperations) InternalQuery

func (pgOps *PostgresOperations) InternalQuery(ctx context.Context, sql string) (result []byte, err error)

InternalQuery is used for internal query, implements BaseInternalOps interface

func (*PostgresOperations) QueryOps

func (pgOps *PostgresOperations) QueryOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

Jump to

Keyboard shortcuts

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