postgres

Documentation

Index

• type PostgresOperations
  • func NewPostgres() *PostgresOperations
  • func (pgOps *PostgresOperations) CheckStatusOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
  • func (pgOps *PostgresOperations) ExecOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)
  • func (pgOps *PostgresOperations) GetLogger() logr.Logger
  • func (pgOps *PostgresOperations) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)
  • func (pgOps *PostgresOperations) GetRunningPort() int
  • func (pgOps *PostgresOperations) Init(metadata Properties) 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 *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

Types

type PostgresOperations

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

PostgresOperations represents PostgreSQL output binding.

func NewPostgres

func NewPostgres() *PostgresOperations

NewPostgres returns a new PostgreSQL output binding.

func (*PostgresOperations) CheckStatusOps

func (pgOps *PostgresOperations) CheckStatusOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

func (*PostgresOperations) ExecOps

func (pgOps *PostgresOperations) ExecOps(ctx context.Context, req *ProbeRequest, resp *ProbeResponse) (OpsResult, error)

func (*PostgresOperations) GetLogger

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

GetLogger is used for getting logger, implements BaseInternalOps interface

func (*PostgresOperations) GetRole

func (pgOps *PostgresOperations) GetRole(ctx context.Context, request *ProbeRequest, response *ProbeResponse) (string, error)

func (*PostgresOperations) GetRunningPort

func (pgOps *PostgresOperations) GetRunningPort() int

func (*PostgresOperations) Init

func (pgOps *PostgresOperations) Init(metadata Properties) 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 *ProbeRequest, resp *ProbeResponse) (OpsResult, error)