Documentation ¶
Index ¶
- type MQTTAttacker
- type MQTTAttackerOption
- func WithMQTTClientPool(p MQTTClientPool) MQTTAttackerOption
- func WithMessageHandler(handler mqtt.MessageHandler) MQTTAttackerOption
- func WithPayloadGenerator(fn func(context.Context) interface{}) MQTTAttackerOption
- func WithQOS(qos byte) MQTTAttackerOption
- func WithRetained(retained bool) MQTTAttackerOption
- func WithTopicSelector(fn TopicSelector) MQTTAttackerOption
- type MQTTClientPool
- type MQTTPublishers
- type MQTTSubscribers
- type PayloadGenerator
- type TopicSelector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTAttacker ¶
type MQTTAttacker interface {
Role() string
ultron.Attacker
}
type MQTTAttackerOption ¶
type MQTTAttackerOption func(MQTTAttacker)
func WithMQTTClientPool ¶ added in v2.5.2
func WithMQTTClientPool(p MQTTClientPool) MQTTAttackerOption
func WithMessageHandler ¶
func WithMessageHandler(handler mqtt.MessageHandler) MQTTAttackerOption
func WithPayloadGenerator ¶ added in v2.5.2
func WithPayloadGenerator(fn func(context.Context) interface{}) MQTTAttackerOption
func WithQOS ¶
func WithQOS(qos byte) MQTTAttackerOption
func WithRetained ¶
func WithRetained(retained bool) MQTTAttackerOption
func WithTopicSelector ¶ added in v2.5.2
func WithTopicSelector(fn TopicSelector) MQTTAttackerOption
type MQTTClientPool ¶ added in v2.5.2
func NewDynamicClientPool ¶ added in v2.5.2
func NewDynamicClientPool(opts *mqtt.ClientOptions) MQTTClientPool
func NewFixedNumberClientPool ¶ added in v2.5.2
func NewFixedNumberClientPool(num int, opts *mqtt.ClientOptions) MQTTClientPool
func NewSingleClientPool ¶ added in v2.5.2
func NewSingleClientPool(opt *mqtt.ClientOptions) MQTTClientPool
type MQTTPublishers ¶ added in v2.5.2
type MQTTPublishers struct {
// contains filtered or unexported fields
}
func NewMQTTPublishers ¶ added in v2.5.2
func NewMQTTPublishers(name string, opts ...MQTTAttackerOption) *MQTTPublishers
func (*MQTTPublishers) Apply ¶ added in v2.5.2
func (pub *MQTTPublishers) Apply(opts ...MQTTAttackerOption)
func (*MQTTPublishers) Fire ¶ added in v2.5.2
func (pub *MQTTPublishers) Fire(ctx context.Context) error
func (*MQTTPublishers) Name ¶ added in v2.5.2
func (pub *MQTTPublishers) Name() string
func (*MQTTPublishers) Role ¶ added in v2.5.2
func (pub *MQTTPublishers) Role() string
type MQTTSubscribers ¶ added in v2.5.2
type MQTTSubscribers struct {
// contains filtered or unexported fields
}
func NewMQTTSubscribers ¶ added in v2.5.2
func NewMQTTSubscribers(name string, opts ...MQTTAttackerOption) *MQTTSubscribers
func (*MQTTSubscribers) Apply ¶ added in v2.5.2
func (sub *MQTTSubscribers) Apply(opts ...MQTTAttackerOption)
func (*MQTTSubscribers) Fire ¶ added in v2.5.2
func (sub *MQTTSubscribers) Fire(ctx context.Context) error
func (*MQTTSubscribers) Name ¶ added in v2.5.2
func (sub *MQTTSubscribers) Name() string
func (*MQTTSubscribers) Role ¶ added in v2.5.2
func (sub *MQTTSubscribers) Role() string
type PayloadGenerator ¶ added in v2.5.2
type TopicSelector ¶ added in v2.5.2
func RoundTripTopics ¶ added in v2.5.2
func RoundTripTopics(topics ...string) TopicSelector
func SingleTopic ¶ added in v2.5.2
func SingleTopic(name string) TopicSelector
Click to show internal directories.
Click to hide internal directories.