Documentation ¶
Index ¶
- type Generator
- func (g *Generator) AsMapBool(c lua.LValue) (interface{}, error)
- func (g *Generator) AsMapFloat(c lua.LValue) (interface{}, error)
- func (g *Generator) AsMapInt(c lua.LValue) (interface{}, error)
- func (g *Generator) AsMapSetInt(c lua.LValue) (interface{}, error)
- func (g *Generator) AsMapSetText(c lua.LValue) (interface{}, error)
- func (g *Generator) AsMapTimestamp(c lua.LValue) (interface{}, error)
- func (g *Generator) AsSetInt(c lua.LValue) ([]int, error)
- func (g *Generator) AsSetMap(c lua.LValue) (interface{}, error)
- func (g *Generator) AsSetText(c lua.LValue) ([]string, error)
- func (g *Generator) AsTimestamp(i int64) time.Time
- func (g *Generator) Finish() error
- func (g *Generator) Init() error
- func (g *Generator) InitDone() error
- func (g *Generator) ObserveConnect(oc gocql.ObservedConnect)
- func (g *Generator) ObserveQuery(ctx context.Context, oq gocql.ObservedQuery)
- func (g *Generator) Tick() error
- type GeneratorOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Generator ¶
func NewGenerator ¶
func (*Generator) AsMapFloat ¶
map<text, float>
func (*Generator) AsMapSetInt ¶
map<string, set<bigint>>
func (*Generator) AsMapSetText ¶
map<string, set<text>>
func (*Generator) AsMapTimestamp ¶
map<text, boolean>
func (*Generator) ObserveConnect ¶
func (g *Generator) ObserveConnect(oc gocql.ObservedConnect)
func (*Generator) ObserveQuery ¶
func (g *Generator) ObserveQuery(ctx context.Context, oq gocql.ObservedQuery)
type GeneratorOptions ¶
type GeneratorOptions struct { Targets []string Query string Keyspace string Consistency string Username string Password string Plaintext bool Insecure bool CaCert string ClientCert string ClientKey string TlsServerName string AstraSecureBundle string // Do not use node information from system.peers table, just use the // manually supplied ones DisablePeersLookup bool IgnorePeerAddr bool ConnectTimeout time.Duration WriteTimeout time.Duration NumConnsPerHost int EnableCompression bool NumRetries int // TODO: configure it ReconnectionPolicy string MaxPreparedStmts int SerialConsistency string HostSelectionPolicy string DCName string WriteCoalesceWaitTime time.Duration TrackMetricsPerNode bool // contains filtered or unexported fields }
func NewOptions ¶
func NewOptions() *GeneratorOptions
Click to show internal directories.
Click to hide internal directories.