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.