k6plugin

Feb 14, 2022

Changes in this version

type NebulaPool

+ func (np *NebulaPool) NewSSLConfig(rootCAPath, certPath, privateKeyPath string)

Aug 12, 2021

Changes in this version

+ var OutputHeader []string = []string

+ type CSVReader struct

+ DataCh chan<- Data

+ Delimiter string

+ Path string

+ WithHeader bool

+ func NewCsvReader(path, delimiter string, withHeader bool, dataCh chan<- Data) *CSVReader

+ func (c *CSVReader) ReadForever() error

+ type CSVReaderStrategy int

+ const AllInOne

+ const Separate

+ type CSVWriter struct

+ DataCh <-chan []string

+ Delimiter string

+ Header []string

+ Path string

+ func NewCsvWriter(path, delimiter string, header []string, dataCh <-chan []string) *CSVWriter

+ func (c *CSVWriter) WriteForever() error

+ type Data []string

+ type NebulaPool struct

+ DataChs []chan Data

+ HostList []nebula.HostAddress

+ Log nebula.Logger

+ OutoptCh chan []string

+ Pool *nebula.ConnectionPool

+ Version string

+ func New() *NebulaPool

+ func (np *NebulaPool) Close() error

+ func (np *NebulaPool) ConfigCSV(path, delimiter string, withHeader bool) error

+ func (np *NebulaPool) ConfigCsvStrategy(strategy int)

+ func (np *NebulaPool) ConfigOutput(path string) error

+ func (np *NebulaPool) GetSession(user, password string) (*NebulaSession, error)

+ func (np *NebulaPool) Init(address string, concurrent int) (*NebulaPool, error)

+ func (np *NebulaPool) InitWithSize(address string, concurrent int, size int) (*NebulaPool, error)

+ type NebulaSession struct

+ DataCh chan Data

+ Pool *NebulaPool

+ Session *nebula.Session

+ func (s *NebulaSession) Execute(stmt string) (*Response, error)

+ func (s *NebulaSession) GetData() (Data, error)

+ func (s *NebulaSession) PrepareCsvReader() error

+ type Output struct

+ ErrorMsg string

+ IsSucceed bool

+ Latency int32

+ NGQL string

+ ResponseTime int32

+ Rows int32

+ TimeStamp int64

+ type Response struct

+ ResponseTime int32

+ func (r *Response) GetResponseTime() int32