Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ClientTypeNames = map[ClientType]string{ ClientTypeEventUnknown: "Unknown", ClientTypeEventProducer: "Event Producer", ClientTypeEventConsumer: "Event Consumer", ClientTypeEventStoreProducer: "EventStore Producer", ClientTypeEventStoreConsumer: "EventStore Consumer", ClientTypeCommandProducer: "Command Producer", ClientTypeCommandConsumer: "Command Consumer", ClientTypeQueryProducer: "Query Producer", ClientTypeQueryConsumer: "Query Consumer", }
ClientTypeNames
View Source
var ScenarioTypesNames = map[string]ScenarioType{ "undefined": ScenarioTypeUndefined, "events": ScenarioTypeEvents, "events_store": ScenarioTypeEventsStore, "commands": ScenarioTypeCommands, "queries": ScenarioTypeQueries, }
ScenarioTypesNames
View Source
var ScenarioTypesStrings = map[ScenarioType]string{ ScenarioTypeUndefined: "undefined", ScenarioTypeEvents: "events", ScenarioTypeEventsStore: "events_store", ScenarioTypeCommands: "commands", ScenarioTypeQueries: "queries", }
ScenarioTypesStrings
Functions ¶
Types ¶
type ClientType ¶
type ClientType int
ClientType - represent client type
const ( ClientTypeEventUnknown ClientType = iota ClientTypeEventProducer ClientTypeEventConsumer ClientTypeEventStoreProducer ClientTypeEventStoreConsumer ClientTypeCommandProducer ClientTypeCommandConsumer ClientTypeQueryProducer ClientTypeQueryConsumer )
type Instance ¶
type Instance struct {
// contains filtered or unexported fields
}
Instance - represent an instance
func NewInstance ¶
func NewInstance(ctx context.Context, cfg *InstanceConfig, connOpts *option.Options) (*Instance, error)
NewInstance
type InstanceConfig ¶
type InstanceConfig struct { Kind ClientType Channel string Group string MessageSize int SendMessagesCount int MessageTimeout time.Duration }
InstanceConfig - represents instance config
type InstanceGroup ¶
type InstanceGroup struct {
// contains filtered or unexported fields
}
InstanceGroup - represents an instance group struct
func NewInstanceGroup ¶
func NewInstanceGroup(ctx context.Context, cfg *InstanceGroupConfig, connOpts *option.Options) (*InstanceGroup, error)
NewInstanceGroup
type InstanceGroupConfig ¶
type InstanceGroupConfig struct { ScenarioType ScenarioType Producers int Consumers int Channel string Group string MessageSize int SendMessagesCount int MessageTimeout time.Duration }
InstanceGroupConfig - represents instance group configuration
type Result ¶
type Result struct { ID string Kind ClientType Messages int Errors []error Latencies []time.Duration }
Result - represent Result struct
type ResultsSet ¶
ResultsSet
type Scenario ¶
type Scenario struct { Name string `json:"name"` Type ScenarioType `json:"type"` Producers int `json:"producers"` Consumers int `json:"consumers"` MessageSize int `json:"message_size"` MessagesToSend int `json:"messages_to_send"` Timeout int `json:"timeout"` }
Scenario - represent scenario struct
type ScenarioType ¶
type ScenarioType int
ScenarioType - represents scenario type
const ( ScenarioTypeUndefined ScenarioType = iota ScenarioTypeEvents ScenarioTypeEventsStore ScenarioTypeCommands ScenarioTypeQueries )
Click to show internal directories.
Click to hide internal directories.