sinks

Documentation

Index

• Constants
• type MQTTSink
  • func (t *MQTTSink) CloseConnection() error
  • func (t *MQTTSink) InitiateConnection(hostname string, port string) error
  • func (t *MQTTSink) SendPayload(payload []byte) (time.Time, error)
  • func (t *MQTTSink) String() string
• type MessageSink
• type NATSSink
  • func (t *NATSSink) CloseConnection() error
  • func (t *NATSSink) InitiateConnection(hostname string, port string) error
  • func (t *NATSSink) SendPayload(payload []byte) (time.Time, error)
  • func (t *NATSSink) String() string
• type PulsarSink
  • func (t *PulsarSink) CloseConnection() error
  • func (t *PulsarSink) InitiateConnection(hostname string, port string) error
  • func (t *PulsarSink) SendPayload(payload []byte) (time.Time, error)
  • func (t *PulsarSink) String() string
• type TCPSink
  • func (t *TCPSink) CloseConnection() error
  • func (t *TCPSink) InitiateConnection(hostname string, port string) error
  • func (t *TCPSink) SendPayload(payload []byte) (time.Time, error)
  • func (t *TCPSink) String() string
• type UDPSink
  • func (t *UDPSink) CloseConnection() error
  • func (t *UDPSink) InitiateConnection(hostname string, port string) error
  • func (t *UDPSink) SendPayload(payload []byte) (time.Time, error)
  • func (t *UDPSink) String() string

Constants

const (
	MqttDefaultPassword = "admin"
	MqttDefaultUsername = "admin"
	MqttDefaultClientId = "admin"
	MqttClientIdLength  = 10

	MqttDefaultCharset = "abcdefghijklmnopqrstuvwxyz"

	MqttDefaultTopic = "test"

	MqttConnectionTimeout = 3
)

const (
	NatsDefaultSubject = "loadtester"
)

const (
	PulsarDefaultTopic = "loadtester"
)

Types

type MQTTSink

type MQTTSink struct {
	Payload []byte
	Client  mqtt.Client
}

MQTTSink is a message sink for a MQTT Connection.

func (*MQTTSink) CloseConnection

func (t *MQTTSink) CloseConnection() error

CloseConnection closes the MQTT link.

func (*MQTTSink) InitiateConnection

func (t *MQTTSink) InitiateConnection(hostname string, port string) error

InitiateConnection connects a new MQTT Connection.

func (*MQTTSink) SendPayload

func (t *MQTTSink) SendPayload(payload []byte) (time.Time, error)

SendPayload sends the payload via the MQTT link.

func (*MQTTSink) String

func (t *MQTTSink) String() string

type MessageSink

type MessageSink interface {
	InitiateConnection(hostname string, port string) error
	SendPayload(payload []byte) (time.Time, error)
	CloseConnection() error
}

MessageSink is the interface used by message routines to send messages.

type NATSSink

type NATSSink struct {
	Payload []byte
	Client  *nats.Conn
}

NATSSink is a message sink for a NATS Subscription.

func (*NATSSink) CloseConnection

func (t *NATSSink) CloseConnection() error

CloseConnection closes the NATS connection.

func (*NATSSink) InitiateConnection

func (t *NATSSink) InitiateConnection(hostname string, port string) error

InitiateConnection starts a NATS Connection

func (*NATSSink) SendPayload

func (t *NATSSink) SendPayload(payload []byte) (time.Time, error)

SendPayload publishes a NATS payload.

func (*NATSSink) String

func (t *NATSSink) String() string

type PulsarSink

type PulsarSink struct {
	Payload  []byte
	Client   pulsar.Client
	Producer pulsar.Producer
}

PulsarSink is a message sink for a NATS Subscription.

func (*PulsarSink) CloseConnection

func (t *PulsarSink) CloseConnection() error

CloseConnection closes the NATS connection.

func (*PulsarSink) InitiateConnection

func (t *PulsarSink) InitiateConnection(hostname string, port string) error

InitiateConnection starts a NATS Connection

func (*PulsarSink) SendPayload

func (t *PulsarSink) SendPayload(payload []byte) (time.Time, error)

SendPayload publishes a NATS payload.

func (*PulsarSink) String

func (t *PulsarSink) String() string

type TCPSink

type TCPSink struct {
	Payload []byte
	Conn    net.Conn
}

TCPSink is a message sink for a Connection.

func (*TCPSink) CloseConnection

func (t *TCPSink) CloseConnection() error

CloseConnection closes the TCP link.

func (*TCPSink) InitiateConnection

func (t *TCPSink) InitiateConnection(hostname string, port string) error

InitiateConnection dials a new TCP Connection.

func (*TCPSink) SendPayload

func (t *TCPSink) SendPayload(payload []byte) (time.Time, error)

SendPayload sends the payload via the TCP link.

func (*TCPSink) String

func (t *TCPSink) String() string

type UDPSink

type UDPSink struct {
	Payload []byte
	Conn    net.Conn
}

UDPSink is a message sink for a Connection.

func (*UDPSink) CloseConnection

func (t *UDPSink) CloseConnection() error

CloseConnection closes the UDP link.

func (*UDPSink) InitiateConnection

func (t *UDPSink) InitiateConnection(hostname string, port string) error

InitiateConnection dials a new UDP Connection.

func (*UDPSink) SendPayload

func (t *UDPSink) SendPayload(payload []byte) (time.Time, error)

SendPayload sends the payload via the UDP link.

func (*UDPSink) String

func (t *UDPSink) String() string