postgres

Documentation

Index

• func NewPostgres(logger logger.Logger) bindings.OutputBinding
• type PostgresOperations
  • func (pgOps *PostgresOperations) CheckStatusOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
  • func (pgOps *PostgresOperations) ExecOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
  • func (pgOps *PostgresOperations) GetLogger() logger.Logger
  • func (pgOps *PostgresOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, ...) (string, error)
  • func (pgOps *PostgresOperations) GetRunningPort() int
  • func (pgOps *PostgresOperations) Init(metadata bindings.Metadata) error
  • func (pgOps *PostgresOperations) InitDelay() error
  • func (pgOps *PostgresOperations) InternalExec(ctx context.Context, sql string) (result int64, err error)
  • func (pgOps *PostgresOperations) InternalQuery(ctx context.Context, sql string) (result []byte, err error)
  • func (pgOps *PostgresOperations) QueryOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)

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)

CheckStatusOps design details: https://infracreate.feishu.cn/wiki/wikcndch7lMZJneMnRqaTvhQpwb#doxcnOUyQ4Mu0KiUo232dOr5aad

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, implement 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) InitDelay

func (pgOps *PostgresOperations) InitDelay() error

func (*PostgresOperations) InternalExec

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

InternalExec is used for internal execution, implement BaseInternalOps interface

func (*PostgresOperations) InternalQuery

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

InternalQuery is used for internal query, implement BaseInternalOps interface

func (*PostgresOperations) QueryOps

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