pkg

type Constructor func() (message.Subscriber, error)

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

type MySQLSchema struct {
	sql.DefaultMySQLSchema
}

type PostgreSQLSchema struct {
	sql.DefaultPostgreSQLSchema
}

type PubSub struct {
	Publisher  message.Publisher
	Subscriber message.Subscriber

	MessagesCount int
	MessageSize   int

	Topic string

	UUIDFunc func() string
}

type PubSubDefinition struct {
	MessagesCount int
	UUIDFunc      func() string
	Constructor   func() (message.Publisher, message.Subscriber)
}

type Results struct {
	Count          int
	MessageSize    int
	MeanRate       float64
	MeanThroughput float64
}