core

Documentation

Index

• type HTTPTransport
  • func (ht *HTTPTransport) Init(url string, token string) error
  • func (ht *HTTPTransport) Transmit(topic string, data []byte) error
• type MQTTTransport
  • func (mt *MQTTTransport) Init(url string, token string) error
  • func (mt *MQTTTransport) Transmit(topic string, data []byte) error
• type Pick
• type Runner
  • func NewRunner(config RunnerConfig) (Runner, error)
  • func (r *Runner) Count() int64
  • func (r *Runner) Run()
  • func (r *Runner) Stop()
• type RunnerConfig
• type Transport

Types

type HTTPTransport

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

HTTPTransport implements transport interface for http/https protocol

func (*HTTPTransport) Init

func (ht *HTTPTransport) Init(url string, token string) error

Init creates a http client

func (*HTTPTransport) Transmit

func (ht *HTTPTransport) Transmit(topic string, data []byte) error

Transmit sends data with given topic that is used as url

type MQTTTransport

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

MQTTTransport implements transport interface for mqtt protocol

func (*MQTTTransport) Init

func (mt *MQTTTransport) Init(url string, token string) error

Init creates and connect mqtt client

func (*MQTTTransport) Transmit

func (mt *MQTTTransport) Transmit(topic string, data []byte) error

Transmit sends data on given mqtt topic

type Pick

type Pick func() interface{}

Pick is called in order to pickup a data for generate method

type Runner

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

Runner runs given generator in specific intervals

func NewRunner

func NewRunner(config RunnerConfig) (Runner, error)

NewRunner creates new runner

func (*Runner) Count

func (r *Runner) Count() int64

Count returns number of generated messages

func (*Runner) Run

func (r *Runner) Run()

Run runs the runner :joy:

func (*Runner) Stop

func (r *Runner) Stop()

Stop stops the runner

type RunnerConfig

type RunnerConfig struct {
	Generator generators.Generator
	Duration  time.Duration
	Pick      Pick
	Token     string
	URL       string
}

RunnerConfig contains runner configuration these configuration specifies host, rate and etc.

type Transport

type Transport interface {
	Init(url string, token string) error
	Transmit(topic string, data []byte) error
}

Transport transports data to given topic based its network protocol