postgres

Documentation

Index

• type PostgresDatabaseOperator
  • func (p *PostgresDatabaseOperator) Handle(msbCtx api.MsbContext, input interface{}) (interface{}, error)
• type PostgresDatabaseOperatorFactory
  • func (p *PostgresDatabaseOperatorFactory) LoadConfig(m map[string]interface{}, i interface{}) (kern.Service, error)
  • func (p *PostgresDatabaseOperatorFactory) Name() string
• type PostgresDatasourceFactory
  • func (p *PostgresDatasourceFactory) LoadConfig(m map[string]interface{}, i interface{}) (kern.Binding, error)
  • func (p *PostgresDatasourceFactory) Name() string
• type PostgresDatasourceProvider
  • func (p *PostgresDatasourceProvider) Bind(msbCtx api.MsbContext, parameter interface{}) (interface{}, error)

Types

type PostgresDatabaseOperator

type PostgresDatabaseOperator struct {
	kern.DefaultService
	// contains filtered or unexported fields
}

func (*PostgresDatabaseOperator) Handle

func (p *PostgresDatabaseOperator) Handle(msbCtx api.MsbContext, input interface{}) (interface{}, error)

type PostgresDatabaseOperatorFactory

type PostgresDatabaseOperatorFactory struct {
}

func (*PostgresDatabaseOperatorFactory) LoadConfig

func (p *PostgresDatabaseOperatorFactory) LoadConfig(m map[string]interface{}, i interface{}) (kern.Service, error)

func (*PostgresDatabaseOperatorFactory) Name

func (p *PostgresDatabaseOperatorFactory) Name() string

type PostgresDatasourceFactory

type PostgresDatasourceFactory struct {
}

func (*PostgresDatasourceFactory) LoadConfig

func (p *PostgresDatasourceFactory) LoadConfig(m map[string]interface{}, i interface{}) (kern.Binding, error)

func (*PostgresDatasourceFactory) Name

func (p *PostgresDatasourceFactory) Name() string

type PostgresDatasourceProvider

type PostgresDatasourceProvider struct {
	kern.DefaultBinding

	ConnectString string
	// contains filtered or unexported fields
}

func (*PostgresDatasourceProvider) Bind

func (p *PostgresDatasourceProvider) Bind(msbCtx api.MsbContext, parameter interface{}) (interface{}, error)