datasource_processor

Documentation

Index

• func UseDataBaseHandler(typ string, handler DataBaseConnectionHandler)
• type DataBaseConnectionHandler
• type DatasourceInjectProcessor
  • func (d *DatasourceInjectProcessor) Do(bean bean.Bean) error
  • func (d *DatasourceInjectProcessor) Filter(bean bean.Bean) bool
• type DatasourceProcessor
  • func (d *DatasourceProcessor) Do(bean bean.Bean) error
  • func (d *DatasourceProcessor) Filter(bean bean.Bean) bool

Functions

func UseDataBaseHandler

func UseDataBaseHandler(typ string, handler DataBaseConnectionHandler)

Types

type DataBaseConnectionHandler

type DataBaseConnectionHandler func(d *DatasourceProcessor, configure data.Datasource) *sql.DB

type DatasourceInjectProcessor

type DatasourceInjectProcessor struct {
	Log logging.Logger `bean:"log"`
}

func (*DatasourceInjectProcessor) Do

func (d *DatasourceInjectProcessor) Do(bean bean.Bean) error

func (*DatasourceInjectProcessor) Filter

func (d *DatasourceInjectProcessor) Filter(bean bean.Bean) bool

type DatasourceProcessor

type DatasourceProcessor struct {
	bean.Component
	Config ssh.Config `value:"ssh"`
	Log    logging.Logger
	// contains filtered or unexported fields
}

func (*DatasourceProcessor) Do

func (d *DatasourceProcessor) Do(bean bean.Bean) error

func (*DatasourceProcessor) Filter

func (d *DatasourceProcessor) Filter(bean bean.Bean) bool