postgresql

Documentation

Index

• func PasswordIdentityDef() *eventline.IdentityDef
• type Connector
  • func NewConnector() *Connector
  • func (c *Connector) DefaultCfg() eventline.ConnectorCfg
  • func (c *Connector) Definition() *eventline.ConnectorDef
  • func (c *Connector) Init(ccfg eventline.ConnectorCfg, initData eventline.ConnectorInitData) error
  • func (c *Connector) Name() string
  • func (c *Connector) Terminate()
• type ConnectorCfg
  • func (cfg *ConnectorCfg) ValidateJSON(v *ejson.Validator)
• type PasswordIdentity
  • func (i *PasswordIdentity) Def() *eventline.IdentityDataDef
  • func (i *PasswordIdentity) Environment() map[string]string
  • func (i *PasswordIdentity) ValidateJSON(v *ejson.Validator)

Functions

func PasswordIdentityDef

func PasswordIdentityDef() *eventline.IdentityDef

Types

type Connector

type Connector struct {
	Def *eventline.ConnectorDef
	Cfg *ConnectorCfg
	Log *log.Logger
}

func NewConnector

func NewConnector() *Connector

func (*Connector) DefaultCfg

func (c *Connector) DefaultCfg() eventline.ConnectorCfg

func (*Connector) Definition

func (c *Connector) Definition() *eventline.ConnectorDef

func (*Connector) Init

func (c *Connector) Init(ccfg eventline.ConnectorCfg, initData eventline.ConnectorInitData) error

func (*Connector) Name

func (c *Connector) Name() string

func (*Connector) Terminate

func (c *Connector) Terminate()

type ConnectorCfg

type ConnectorCfg struct {
}

func (*ConnectorCfg) ValidateJSON

func (cfg *ConnectorCfg) ValidateJSON(v *ejson.Validator)

type PasswordIdentity

type PasswordIdentity struct {
	User     string `json:"user"`
	Password string `json:"password"`
}

func (*PasswordIdentity) Def

func (i *PasswordIdentity) Def() *eventline.IdentityDataDef

func (*PasswordIdentity) Environment

func (i *PasswordIdentity) Environment() map[string]string

func (*PasswordIdentity) ValidateJSON

func (i *PasswordIdentity) ValidateJSON(v *ejson.Validator)