postgres

Documentation

Index

• func NewPostgres(logger logger.Logger) bindings.OutputBinding
• type Postgres
  • func (p *Postgres) Close() error
  • func (p *Postgres) Init(metadata bindings.Metadata) error
  • func (p *Postgres) Invoke(ctx context.Context, req *bindings.InvokeRequest) (resp *bindings.InvokeResponse, err error)
  • func (p *Postgres) Operations() []bindings.OperationKind

Functions

func NewPostgres

func NewPostgres(logger logger.Logger) bindings.OutputBinding

NewPostgres returns a new PostgreSQL output binding.

Types

type Postgres

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

Postgres represents PostgreSQL output binding.

func (*Postgres) Close

func (p *Postgres) Close() error

Close close PostgreSql instance.

func (*Postgres) Init

func (p *Postgres) Init(metadata bindings.Metadata) error

Init initializes the PostgreSql binding.

func (*Postgres) Invoke

func (p *Postgres) Invoke(ctx context.Context, req *bindings.InvokeRequest) (resp *bindings.InvokeResponse, err error)

Invoke handles all invoke operations.

func (*Postgres) Operations

func (p *Postgres) Operations() []bindings.OperationKind

Operations returns list of operations supported by PostgreSql binding.