target

Documentation

Index

• Variables
• func LoadTt()
• func NewCodecTarget(rx typex.RuleX) typex.XTarget
• func NewHTTPTarget(e typex.RuleX) typex.XTarget
• func NewMongoTarget(e typex.RuleX) typex.XTarget
• func NewMqttTarget(e typex.RuleX) typex.XTarget
• func NewNatsTarget(e typex.RuleX) typex.XTarget
• func NewSqliteTarget(e typex.RuleX) typex.XTarget
• func NewTTcpTarget(e typex.RuleX) typex.XTarget
• func NewTdEngineTarget(e typex.RuleX) typex.XTarget
• func NewUdpTarget(e typex.RuleX) typex.XTarget
• func NewUserG776(e typex.RuleX) typex.XTarget
• type HTTPTarget
  • func (ht *HTTPTarget) Details() *typex.OutEnd
  • func (ht *HTTPTarget) Init(outEndId string, configMap map[string]interface{}) error
  • func (ht *HTTPTarget) Start(cctx typex.CCTX) error
  • func (ht *HTTPTarget) Status() typex.SourceState
  • func (ht *HTTPTarget) Stop()
  • func (ht *HTTPTarget) To(data interface{}) (interface{}, error)
• type SqliteTarget
  • func (sqt *SqliteTarget) Details() *typex.OutEnd
  • func (sqt *SqliteTarget) Init(outEndId string, configMap map[string]interface{}) error
  • func (sqt *SqliteTarget) Start(cctx typex.CCTX) error
  • func (sqt *SqliteTarget) Status() typex.SourceState
  • func (sqt *SqliteTarget) Stop()
  • func (sqt *SqliteTarget) To(data interface{}) (interface{}, error)
• type TTcpTarget
  • func (ht *TTcpTarget) Details() *typex.OutEnd
  • func (ht *TTcpTarget) Init(outEndId string, configMap map[string]interface{}) error
  • func (ht *TTcpTarget) Start(cctx typex.CCTX) error
  • func (ht *TTcpTarget) Status() typex.SourceState
  • func (ht *TTcpTarget) Stop()
  • func (ht *TTcpTarget) To(data interface{}) (interface{}, error)
• type UdpTarget
  • func (udpT *UdpTarget) Details() *typex.OutEnd
  • func (udpT *UdpTarget) Init(outEndId string, configMap map[string]interface{}) error
  • func (udpT *UdpTarget) Start(cctx typex.CCTX) error
  • func (udpT *UdpTarget) Status() typex.SourceState
  • func (udpT *UdpTarget) Stop()
  • func (udpT *UdpTarget) To(data interface{}) (interface{}, error)
  • func (udpT *UdpTarget) UdpStatus(serverAddr string) error

Variables

var TM typex.TargetRegistry

Functions

func LoadTt

func LoadTt()

func NewCodecTarget

func NewCodecTarget(rx typex.RuleX) typex.XTarget

func NewHTTPTarget

func NewHTTPTarget(e typex.RuleX) typex.XTarget

func NewMongoTarget

func NewMongoTarget(e typex.RuleX) typex.XTarget

func NewMqttTarget

func NewMqttTarget(e typex.RuleX) typex.XTarget

func NewNatsTarget

func NewNatsTarget(e typex.RuleX) typex.XTarget

func NewSqliteTarget

func NewSqliteTarget(e typex.RuleX) typex.XTarget

func NewTTcpTarget

func NewTTcpTarget(e typex.RuleX) typex.XTarget

* * TCP 透传模式 *

func NewTdEngineTarget

func NewTdEngineTarget(e typex.RuleX) typex.XTarget

func NewUdpTarget

func NewUdpTarget(e typex.RuleX) typex.XTarget

func NewUserG776

func NewUserG776(e typex.RuleX) typex.XTarget

Types

type HTTPTarget

type HTTPTarget struct {
	typex.XStatus
	// contains filtered or unexported fields
}

func (*HTTPTarget) Details

func (ht *HTTPTarget) Details() *typex.OutEnd

func (*HTTPTarget) Init

func (ht *HTTPTarget) Init(outEndId string, configMap map[string]interface{}) error

func (*HTTPTarget) Start

func (ht *HTTPTarget) Start(cctx typex.CCTX) error

func (*HTTPTarget) Status

func (ht *HTTPTarget) Status() typex.SourceState

func (*HTTPTarget) Stop

func (ht *HTTPTarget) Stop()

func (*HTTPTarget) To

func (ht *HTTPTarget) To(data interface{}) (interface{}, error)

type SqliteTarget

type SqliteTarget struct {
	typex.XStatus
	// contains filtered or unexported fields
}

func (*SqliteTarget) Details

func (sqt *SqliteTarget) Details() *typex.OutEnd

func (*SqliteTarget) Init

func (sqt *SqliteTarget) Init(outEndId string, configMap map[string]interface{}) error

func (*SqliteTarget) Start

func (sqt *SqliteTarget) Start(cctx typex.CCTX) error

func (*SqliteTarget) Status

func (sqt *SqliteTarget) Status() typex.SourceState

func (*SqliteTarget) Stop

func (sqt *SqliteTarget) Stop()

func (*SqliteTarget) To

func (sqt *SqliteTarget) To(data interface{}) (interface{}, error)

* * 数据转存SQLITE *

type TTcpTarget

type TTcpTarget struct {
	typex.XStatus
	// contains filtered or unexported fields
}

func (*TTcpTarget) Details

func (ht *TTcpTarget) Details() *typex.OutEnd

func (*TTcpTarget) Init

func (ht *TTcpTarget) Init(outEndId string, configMap map[string]interface{}) error

func (*TTcpTarget) Start

func (ht *TTcpTarget) Start(cctx typex.CCTX) error

func (*TTcpTarget) Status

func (ht *TTcpTarget) Status() typex.SourceState

func (*TTcpTarget) Stop

func (ht *TTcpTarget) Stop()

func (*TTcpTarget) To

func (ht *TTcpTarget) To(data interface{}) (interface{}, error)

* * 透传模式：字符串和十六进制 *

type UdpTarget

type UdpTarget struct {
	typex.XStatus
	// contains filtered or unexported fields
}

* * 数据推到UDP *

func (*UdpTarget) Details

func (udpT *UdpTarget) Details() *typex.OutEnd

func (*UdpTarget) Init

func (udpT *UdpTarget) Init(outEndId string, configMap map[string]interface{}) error

func (*UdpTarget) Start

func (udpT *UdpTarget) Start(cctx typex.CCTX) error

func (*UdpTarget) Status

func (udpT *UdpTarget) Status() typex.SourceState

func (*UdpTarget) Stop

func (udpT *UdpTarget) Stop()

func (*UdpTarget) To

func (udpT *UdpTarget) To(data interface{}) (interface{}, error)

func (*UdpTarget) UdpStatus

func (udpT *UdpTarget) UdpStatus(serverAddr string) error