extensions

Documentation

Index

• Constants
• func CastToString(v interface{}) (result string, ok bool)
• type HTTPPullSource
  • func (hps *HTTPPullSource) Close(ctx api.StreamContext) error
  • func (hps *HTTPPullSource) Configure(device, jsonConfig string, props map[string]interface{}) error
  • func (hps *HTTPPullSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)
• type MQTTConfig
• type MQTTSource
  • func (ms *MQTTSource) Close(ctx api.StreamContext) error
  • func (ms *MQTTSource) Configure(topic, jsonConfig string, props map[string]interface{}) error
  • func (ms *MQTTSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)
  • func (ms *MQTTSource) WithSchema(schema string) *MQTTSource

Constants

const DEFAULT_INTERVAL = 10000

const DEFAULT_TIMEOUT = 5000

Functions

func CastToString

func CastToString(v interface{}) (result string, ok bool)

Types

type HTTPPullSource

type HTTPPullSource struct {
	// contains filtered or unexported fields
}

func (*HTTPPullSource) Close

func (hps *HTTPPullSource) Close(ctx api.StreamContext) error

func (*HTTPPullSource) Configure

func (hps *HTTPPullSource) Configure(device, jsonConfig string, props map[string]interface{}) error

func (*HTTPPullSource) Open

func (hps *HTTPPullSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)

type MQTTConfig

type MQTTConfig struct {
	Format            string   `json:"format"`
	Qos               int      `json:"qos"`
	Servers           []string `json:"servers"`
	Clientid          string   `json:"clientid"`
	PVersion          string   `json:"protocolVersion"`
	Uname             string   `json:"username"`
	Password          string   `json:"password"`
	Certification     string   `json:"certificationPath"`
	PrivateKPath      string   `json:"privateKeyPath"`
	KubeedgeModelFile string   `json:"kubeedgeModelFile"`
	KubeedgeVersion   string   `json:"kubeedgeVersion"`
}

type MQTTSource

type MQTTSource struct {
	// contains filtered or unexported fields
}

func (*MQTTSource) Close

func (ms *MQTTSource) Close(ctx api.StreamContext) error

func (*MQTTSource) Configure

func (ms *MQTTSource) Configure(topic, jsonConfig string, props map[string]interface{}) error

func (*MQTTSource) Open

func (ms *MQTTSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)

func (*MQTTSource) WithSchema

func (ms *MQTTSource) WithSchema(schema string) *MQTTSource