datasource_processor

Documentation

Index

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

Functions

func UseDataBaseHandler

func UseDataBaseHandler(typ string, handler DataBaseHandler)

Types

type DataBaseHandler

type DataBaseHandler func(d *DatasourceProcessor, configure data.Configure) data.DatasourceWrapper

type DatasourceInjectProcessor

type DatasourceInjectProcessor struct {
	Log *logrus.Logger
}

func (*DatasourceInjectProcessor) Do

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

func (*DatasourceInjectProcessor) Filter

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

type DatasourceProcessor

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

func (*DatasourceProcessor) Do

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

func (*DatasourceProcessor) Filter

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