Documentation
¶
Overview ¶
Package kinesis implements a Kinesis client for k6.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncClient ¶
type AsyncClient struct {
// contains filtered or unexported fields
}
AsyncClient represents the AsyncClient constructor (i.e., `new kinesis.AsyncClient()`) and returns a new asynchronous Kinesis client object.
func (*AsyncClient) PutRecord ¶
func (c *AsyncClient) PutRecord(putRecordInput interface{}) *goja.Promise
PutRecord asynchronously writes a single data record into a Kinesis data stream.
func (*AsyncClient) PutRecords ¶
func (c *AsyncClient) PutRecords(putRecordsInput interface{}) *goja.Promise
PutRecords asynchronously writes multiple data records into a Kinesis data stream in a single call.
type ModuleInstance ¶
type ModuleInstance struct {
// contains filtered or unexported fields
}
ModuleInstance represents an instance of the JS module for every VU.
func (*ModuleInstance) Exports ¶
func (mi *ModuleInstance) Exports() modules.Exports
Exports implements the modules.Instance interface and returns the exports of the JS module.
func (*ModuleInstance) NewAsyncClient ¶
func (mi *ModuleInstance) NewAsyncClient(call goja.ConstructorCall) *goja.Object
NewAsyncClient is the JS constructor for the asynchronous Kinesis client based on the AWS SDK implementation.
func (*ModuleInstance) NewClient ¶
func (mi *ModuleInstance) NewClient(call goja.ConstructorCall) *goja.Object
NewClient is the JS constructor for the default synchronous Kinesis client based on the AWS SDK implementation.
type RootModule ¶
type RootModule struct{}
RootModule is the global module object type. It is instantiated once per test run and will be used to create `k6/x/kinesis` module instances for each VU.
func (*RootModule) NewModuleInstance ¶
func (*RootModule) NewModuleInstance(vu modules.VU) modules.Instance
NewModuleInstance implements the modules.Module interface to return a new instance for each VU.
type SyncClient ¶
type SyncClient struct {
// contains filtered or unexported fields
}
SyncClient represents the synchronous Client constructor (i.e., `new kinesis.Client()`) and returns a new synchronous Kinesis client object.
func (*SyncClient) PutRecord ¶
func (c *SyncClient) PutRecord(putRecordInput interface{}) (interface{}, error)
PutRecord synchronously writes a single data record into a Kinesis data stream.
func (*SyncClient) PutRecords ¶
func (c *SyncClient) PutRecords(putRecordsInput interface{}) (interface{}, error)
PutRecords synchronously writes multiple data records into a Kinesis data stream in a single call.
Source Files