mocks

package
v0.21.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 12, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Checkpoint 

type Checkpoint struct {
	mock.Mock
}

Checkpoint is an autogenerated mock type for the Checkpoint type

func NewCheckpoint 

func NewCheckpoint(t interface {
	mock.TestingT
	Cleanup(func())
}) *Checkpoint

NewCheckpoint creates a new instance of Checkpoint. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Checkpoint) Advance 

func (_m *Checkpoint) Advance(sequenceNumber kinesis.SequenceNumber, shardIterator kinesis.ShardIterator) error

Advance provides a mock function with given fields: sequenceNumber, shardIterator

func (*Checkpoint) Done 

func (_m *Checkpoint) Done(sequenceNumber kinesis.SequenceNumber) error

Done provides a mock function with given fields: sequenceNumber

func (*Checkpoint) EXPECT 

func (_m *Checkpoint) EXPECT() *Checkpoint_Expecter

func (*Checkpoint) GetSequenceNumber 

func (_m *Checkpoint) GetSequenceNumber() kinesis.SequenceNumber

GetSequenceNumber provides a mock function with given fields:

func (*Checkpoint) GetShardIterator added in v0.21.0 

func (_m *Checkpoint) GetShardIterator() kinesis.ShardIterator

GetShardIterator provides a mock function with given fields:

func (*Checkpoint) Persist 

func (_m *Checkpoint) Persist(ctx context.Context) (bool, error)

Persist provides a mock function with given fields: ctx

func (*Checkpoint) Release 

func (_m *Checkpoint) Release(ctx context.Context) error

Release provides a mock function with given fields: ctx

type CheckpointWithoutRelease 

type CheckpointWithoutRelease struct {
	mock.Mock
}

CheckpointWithoutRelease is an autogenerated mock type for the CheckpointWithoutRelease type

func NewCheckpointWithoutRelease 

func NewCheckpointWithoutRelease(t interface {
	mock.TestingT
	Cleanup(func())
}) *CheckpointWithoutRelease

NewCheckpointWithoutRelease creates a new instance of CheckpointWithoutRelease. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CheckpointWithoutRelease) Advance 

func (_m *CheckpointWithoutRelease) Advance(sequenceNumber kinesis.SequenceNumber, shardIterator kinesis.ShardIterator) error

Advance provides a mock function with given fields: sequenceNumber, shardIterator

func (*CheckpointWithoutRelease) Done 

func (_m *CheckpointWithoutRelease) Done(sequenceNumber kinesis.SequenceNumber) error

Done provides a mock function with given fields: sequenceNumber

func (*CheckpointWithoutRelease) EXPECT 

func (_m *CheckpointWithoutRelease) EXPECT() *CheckpointWithoutRelease_Expecter

func (*CheckpointWithoutRelease) GetSequenceNumber 

func (_m *CheckpointWithoutRelease) GetSequenceNumber() kinesis.SequenceNumber

GetSequenceNumber provides a mock function with given fields:

func (*CheckpointWithoutRelease) GetShardIterator added in v0.21.0 

func (_m *CheckpointWithoutRelease) GetShardIterator() kinesis.ShardIterator

GetShardIterator provides a mock function with given fields:

func (*CheckpointWithoutRelease) Persist 

func (_m *CheckpointWithoutRelease) Persist(ctx context.Context) (bool, error)

Persist provides a mock function with given fields: ctx

type CheckpointWithoutRelease_Advance_Call 

type CheckpointWithoutRelease_Advance_Call struct {
	*mock.Call
}

CheckpointWithoutRelease_Advance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Advance'

func (*CheckpointWithoutRelease_Advance_Call) Return 

func (_c *CheckpointWithoutRelease_Advance_Call) Return(_a0 error) *CheckpointWithoutRelease_Advance_Call

func (*CheckpointWithoutRelease_Advance_Call) Run 

func (_c *CheckpointWithoutRelease_Advance_Call) Run(run func(sequenceNumber kinesis.SequenceNumber, shardIterator kinesis.ShardIterator)) *CheckpointWithoutRelease_Advance_Call

func (*CheckpointWithoutRelease_Advance_Call) RunAndReturn 

func (_c *CheckpointWithoutRelease_Advance_Call) RunAndReturn(run func(kinesis.SequenceNumber, kinesis.ShardIterator) error) *CheckpointWithoutRelease_Advance_Call

type CheckpointWithoutRelease_Done_Call 

type CheckpointWithoutRelease_Done_Call struct {
	*mock.Call
}

CheckpointWithoutRelease_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*CheckpointWithoutRelease_Done_Call) Return 

func (_c *CheckpointWithoutRelease_Done_Call) Return(_a0 error) *CheckpointWithoutRelease_Done_Call

func (*CheckpointWithoutRelease_Done_Call) Run 

func (_c *CheckpointWithoutRelease_Done_Call) Run(run func(sequenceNumber kinesis.SequenceNumber)) *CheckpointWithoutRelease_Done_Call

func (*CheckpointWithoutRelease_Done_Call) RunAndReturn 

func (_c *CheckpointWithoutRelease_Done_Call) RunAndReturn(run func(kinesis.SequenceNumber) error) *CheckpointWithoutRelease_Done_Call

type CheckpointWithoutRelease_Expecter 

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

func (*CheckpointWithoutRelease_Expecter) Advance 

func (_e *CheckpointWithoutRelease_Expecter) Advance(sequenceNumber interface{}, shardIterator interface{}) *CheckpointWithoutRelease_Advance_Call

Advance is a helper method to define mock.On call

  • sequenceNumber kinesis.SequenceNumber
  • shardIterator kinesis.ShardIterator

func (*CheckpointWithoutRelease_Expecter) Done 

func (_e *CheckpointWithoutRelease_Expecter) Done(sequenceNumber interface{}) *CheckpointWithoutRelease_Done_Call

Done is a helper method to define mock.On call

  • sequenceNumber kinesis.SequenceNumber

func (*CheckpointWithoutRelease_Expecter) GetSequenceNumber 

func (_e *CheckpointWithoutRelease_Expecter) GetSequenceNumber() *CheckpointWithoutRelease_GetSequenceNumber_Call

GetSequenceNumber is a helper method to define mock.On call

func (*CheckpointWithoutRelease_Expecter) GetShardIterator added in v0.21.0 

func (_e *CheckpointWithoutRelease_Expecter) GetShardIterator() *CheckpointWithoutRelease_GetShardIterator_Call

GetShardIterator is a helper method to define mock.On call

func (*CheckpointWithoutRelease_Expecter) Persist 

func (_e *CheckpointWithoutRelease_Expecter) Persist(ctx interface{}) *CheckpointWithoutRelease_Persist_Call

Persist is a helper method to define mock.On call

  • ctx context.Context

type CheckpointWithoutRelease_GetSequenceNumber_Call 

type CheckpointWithoutRelease_GetSequenceNumber_Call struct {
	*mock.Call
}

CheckpointWithoutRelease_GetSequenceNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSequenceNumber'

func (*CheckpointWithoutRelease_GetSequenceNumber_Call) Return 

func (_c *CheckpointWithoutRelease_GetSequenceNumber_Call) Return(_a0 kinesis.SequenceNumber) *CheckpointWithoutRelease_GetSequenceNumber_Call

func (*CheckpointWithoutRelease_GetSequenceNumber_Call) Run 

func (_c *CheckpointWithoutRelease_GetSequenceNumber_Call) Run(run func()) *CheckpointWithoutRelease_GetSequenceNumber_Call

func (*CheckpointWithoutRelease_GetSequenceNumber_Call) RunAndReturn 

func (_c *CheckpointWithoutRelease_GetSequenceNumber_Call) RunAndReturn(run func() kinesis.SequenceNumber) *CheckpointWithoutRelease_GetSequenceNumber_Call

type CheckpointWithoutRelease_GetShardIterator_Call added in v0.21.0 

type CheckpointWithoutRelease_GetShardIterator_Call struct {
	*mock.Call
}

CheckpointWithoutRelease_GetShardIterator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetShardIterator'

func (*CheckpointWithoutRelease_GetShardIterator_Call) Return added in v0.21.0 

func (_c *CheckpointWithoutRelease_GetShardIterator_Call) Return(_a0 kinesis.ShardIterator) *CheckpointWithoutRelease_GetShardIterator_Call

func (*CheckpointWithoutRelease_GetShardIterator_Call) Run added in v0.21.0 

func (_c *CheckpointWithoutRelease_GetShardIterator_Call) Run(run func()) *CheckpointWithoutRelease_GetShardIterator_Call

func (*CheckpointWithoutRelease_GetShardIterator_Call) RunAndReturn added in v0.21.0 

func (_c *CheckpointWithoutRelease_GetShardIterator_Call) RunAndReturn(run func() kinesis.ShardIterator) *CheckpointWithoutRelease_GetShardIterator_Call

type CheckpointWithoutRelease_Persist_Call 

type CheckpointWithoutRelease_Persist_Call struct {
	*mock.Call
}

CheckpointWithoutRelease_Persist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Persist'

func (*CheckpointWithoutRelease_Persist_Call) Return 

func (_c *CheckpointWithoutRelease_Persist_Call) Return(shouldRelease bool, err error) *CheckpointWithoutRelease_Persist_Call

func (*CheckpointWithoutRelease_Persist_Call) Run 

func (_c *CheckpointWithoutRelease_Persist_Call) Run(run func(ctx context.Context)) *CheckpointWithoutRelease_Persist_Call

func (*CheckpointWithoutRelease_Persist_Call) RunAndReturn 

func (_c *CheckpointWithoutRelease_Persist_Call) RunAndReturn(run func(context.Context) (bool, error)) *CheckpointWithoutRelease_Persist_Call

type Checkpoint_Advance_Call 

type Checkpoint_Advance_Call struct {
	*mock.Call
}

Checkpoint_Advance_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Advance'

func (*Checkpoint_Advance_Call) Return 

func (_c *Checkpoint_Advance_Call) Return(_a0 error) *Checkpoint_Advance_Call

func (*Checkpoint_Advance_Call) Run 

func (_c *Checkpoint_Advance_Call) Run(run func(sequenceNumber kinesis.SequenceNumber, shardIterator kinesis.ShardIterator)) *Checkpoint_Advance_Call

func (*Checkpoint_Advance_Call) RunAndReturn 

func (_c *Checkpoint_Advance_Call) RunAndReturn(run func(kinesis.SequenceNumber, kinesis.ShardIterator) error) *Checkpoint_Advance_Call

type Checkpoint_Done_Call 

type Checkpoint_Done_Call struct {
	*mock.Call
}

Checkpoint_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*Checkpoint_Done_Call) Return 

func (_c *Checkpoint_Done_Call) Return(_a0 error) *Checkpoint_Done_Call

func (*Checkpoint_Done_Call) Run 

func (_c *Checkpoint_Done_Call) Run(run func(sequenceNumber kinesis.SequenceNumber)) *Checkpoint_Done_Call

func (*Checkpoint_Done_Call) RunAndReturn 

func (_c *Checkpoint_Done_Call) RunAndReturn(run func(kinesis.SequenceNumber) error) *Checkpoint_Done_Call

type Checkpoint_Expecter 

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

func (*Checkpoint_Expecter) Advance 

func (_e *Checkpoint_Expecter) Advance(sequenceNumber interface{}, shardIterator interface{}) *Checkpoint_Advance_Call

Advance is a helper method to define mock.On call

  • sequenceNumber kinesis.SequenceNumber
  • shardIterator kinesis.ShardIterator

func (*Checkpoint_Expecter) Done 

func (_e *Checkpoint_Expecter) Done(sequenceNumber interface{}) *Checkpoint_Done_Call

Done is a helper method to define mock.On call

  • sequenceNumber kinesis.SequenceNumber

func (*Checkpoint_Expecter) GetSequenceNumber 

func (_e *Checkpoint_Expecter) GetSequenceNumber() *Checkpoint_GetSequenceNumber_Call

GetSequenceNumber is a helper method to define mock.On call

func (*Checkpoint_Expecter) GetShardIterator added in v0.21.0 

func (_e *Checkpoint_Expecter) GetShardIterator() *Checkpoint_GetShardIterator_Call

GetShardIterator is a helper method to define mock.On call

func (*Checkpoint_Expecter) Persist 

func (_e *Checkpoint_Expecter) Persist(ctx interface{}) *Checkpoint_Persist_Call

Persist is a helper method to define mock.On call

  • ctx context.Context

func (*Checkpoint_Expecter) Release 

func (_e *Checkpoint_Expecter) Release(ctx interface{}) *Checkpoint_Release_Call

Release is a helper method to define mock.On call

  • ctx context.Context

type Checkpoint_GetSequenceNumber_Call 

type Checkpoint_GetSequenceNumber_Call struct {
	*mock.Call
}

Checkpoint_GetSequenceNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSequenceNumber'

func (*Checkpoint_GetSequenceNumber_Call) Return 

func (_c *Checkpoint_GetSequenceNumber_Call) Return(_a0 kinesis.SequenceNumber) *Checkpoint_GetSequenceNumber_Call

func (*Checkpoint_GetSequenceNumber_Call) Run 

func (_c *Checkpoint_GetSequenceNumber_Call) Run(run func()) *Checkpoint_GetSequenceNumber_Call

func (*Checkpoint_GetSequenceNumber_Call) RunAndReturn 

func (_c *Checkpoint_GetSequenceNumber_Call) RunAndReturn(run func() kinesis.SequenceNumber) *Checkpoint_GetSequenceNumber_Call

type Checkpoint_GetShardIterator_Call added in v0.21.0 

type Checkpoint_GetShardIterator_Call struct {
	*mock.Call
}

Checkpoint_GetShardIterator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetShardIterator'

func (*Checkpoint_GetShardIterator_Call) Return added in v0.21.0 

func (_c *Checkpoint_GetShardIterator_Call) Return(_a0 kinesis.ShardIterator) *Checkpoint_GetShardIterator_Call

func (*Checkpoint_GetShardIterator_Call) Run added in v0.21.0 

func (_c *Checkpoint_GetShardIterator_Call) Run(run func()) *Checkpoint_GetShardIterator_Call

func (*Checkpoint_GetShardIterator_Call) RunAndReturn added in v0.21.0 

func (_c *Checkpoint_GetShardIterator_Call) RunAndReturn(run func() kinesis.ShardIterator) *Checkpoint_GetShardIterator_Call

type Checkpoint_Persist_Call 

type Checkpoint_Persist_Call struct {
	*mock.Call
}

Checkpoint_Persist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Persist'

func (*Checkpoint_Persist_Call) Return 

func (_c *Checkpoint_Persist_Call) Return(shouldRelease bool, err error) *Checkpoint_Persist_Call

func (*Checkpoint_Persist_Call) Run 

func (_c *Checkpoint_Persist_Call) Run(run func(ctx context.Context)) *Checkpoint_Persist_Call

func (*Checkpoint_Persist_Call) RunAndReturn 

func (_c *Checkpoint_Persist_Call) RunAndReturn(run func(context.Context) (bool, error)) *Checkpoint_Persist_Call

type Checkpoint_Release_Call 

type Checkpoint_Release_Call struct {
	*mock.Call
}

Checkpoint_Release_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Release'

func (*Checkpoint_Release_Call) Return 

func (_c *Checkpoint_Release_Call) Return(_a0 error) *Checkpoint_Release_Call

func (*Checkpoint_Release_Call) Run 

func (_c *Checkpoint_Release_Call) Run(run func(ctx context.Context)) *Checkpoint_Release_Call

func (*Checkpoint_Release_Call) RunAndReturn 

func (_c *Checkpoint_Release_Call) RunAndReturn(run func(context.Context) error) *Checkpoint_Release_Call

type Client 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewClient 

func NewClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *Client

NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Client) AddTagsToStream 

func (_m *Client) AddTagsToStream(ctx context.Context, params *kinesis.AddTagsToStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.AddTagsToStreamOutput, error)

AddTagsToStream provides a mock function with given fields: ctx, params, optFns

func (*Client) CreateStream 

func (_m *Client) CreateStream(ctx context.Context, params *kinesis.CreateStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.CreateStreamOutput, error)

CreateStream provides a mock function with given fields: ctx, params, optFns

func (*Client) DecreaseStreamRetentionPeriod 

func (_m *Client) DecreaseStreamRetentionPeriod(ctx context.Context, params *kinesis.DecreaseStreamRetentionPeriodInput, optFns ...func(*kinesis.Options)) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)

DecreaseStreamRetentionPeriod provides a mock function with given fields: ctx, params, optFns

func (*Client) DeleteStream 

func (_m *Client) DeleteStream(ctx context.Context, params *kinesis.DeleteStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.DeleteStreamOutput, error)

DeleteStream provides a mock function with given fields: ctx, params, optFns

func (*Client) DeregisterStreamConsumer 

func (_m *Client) DeregisterStreamConsumer(ctx context.Context, params *kinesis.DeregisterStreamConsumerInput, optFns ...func(*kinesis.Options)) (*kinesis.DeregisterStreamConsumerOutput, error)

DeregisterStreamConsumer provides a mock function with given fields: ctx, params, optFns

func (*Client) DescribeLimits 

func (_m *Client) DescribeLimits(ctx context.Context, params *kinesis.DescribeLimitsInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeLimitsOutput, error)

DescribeLimits provides a mock function with given fields: ctx, params, optFns

func (*Client) DescribeStream 

func (_m *Client) DescribeStream(ctx context.Context, params *kinesis.DescribeStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamOutput, error)

DescribeStream provides a mock function with given fields: ctx, params, optFns

func (*Client) DescribeStreamConsumer 

func (_m *Client) DescribeStreamConsumer(ctx context.Context, params *kinesis.DescribeStreamConsumerInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamConsumerOutput, error)

DescribeStreamConsumer provides a mock function with given fields: ctx, params, optFns

func (*Client) DescribeStreamSummary 

func (_m *Client) DescribeStreamSummary(ctx context.Context, params *kinesis.DescribeStreamSummaryInput, optFns ...func(*kinesis.Options)) (*kinesis.DescribeStreamSummaryOutput, error)

DescribeStreamSummary provides a mock function with given fields: ctx, params, optFns

func (*Client) DisableEnhancedMonitoring 

func (_m *Client) DisableEnhancedMonitoring(ctx context.Context, params *kinesis.DisableEnhancedMonitoringInput, optFns ...func(*kinesis.Options)) (*kinesis.DisableEnhancedMonitoringOutput, error)

DisableEnhancedMonitoring provides a mock function with given fields: ctx, params, optFns

func (*Client) EXPECT 

func (_m *Client) EXPECT() *Client_Expecter

func (*Client) EnableEnhancedMonitoring 

func (_m *Client) EnableEnhancedMonitoring(ctx context.Context, params *kinesis.EnableEnhancedMonitoringInput, optFns ...func(*kinesis.Options)) (*kinesis.EnableEnhancedMonitoringOutput, error)

EnableEnhancedMonitoring provides a mock function with given fields: ctx, params, optFns

func (*Client) GetRecords 

func (_m *Client) GetRecords(ctx context.Context, params *kinesis.GetRecordsInput, optFns ...func(*kinesis.Options)) (*kinesis.GetRecordsOutput, error)

GetRecords provides a mock function with given fields: ctx, params, optFns

func (*Client) GetShardIterator 

func (_m *Client) GetShardIterator(ctx context.Context, params *kinesis.GetShardIteratorInput, optFns ...func(*kinesis.Options)) (*kinesis.GetShardIteratorOutput, error)

GetShardIterator provides a mock function with given fields: ctx, params, optFns

func (*Client) IncreaseStreamRetentionPeriod 

func (_m *Client) IncreaseStreamRetentionPeriod(ctx context.Context, params *kinesis.IncreaseStreamRetentionPeriodInput, optFns ...func(*kinesis.Options)) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)

IncreaseStreamRetentionPeriod provides a mock function with given fields: ctx, params, optFns

func (*Client) ListShards 

func (_m *Client) ListShards(ctx context.Context, params *kinesis.ListShardsInput, optFns ...func(*kinesis.Options)) (*kinesis.ListShardsOutput, error)

ListShards provides a mock function with given fields: ctx, params, optFns

func (*Client) ListStreamConsumers 

func (_m *Client) ListStreamConsumers(ctx context.Context, params *kinesis.ListStreamConsumersInput, optFns ...func(*kinesis.Options)) (*kinesis.ListStreamConsumersOutput, error)

ListStreamConsumers provides a mock function with given fields: ctx, params, optFns

func (*Client) ListStreams 

func (_m *Client) ListStreams(ctx context.Context, params *kinesis.ListStreamsInput, optFns ...func(*kinesis.Options)) (*kinesis.ListStreamsOutput, error)

ListStreams provides a mock function with given fields: ctx, params, optFns

func (*Client) ListTagsForStream 

func (_m *Client) ListTagsForStream(ctx context.Context, params *kinesis.ListTagsForStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.ListTagsForStreamOutput, error)

ListTagsForStream provides a mock function with given fields: ctx, params, optFns

func (*Client) MergeShards 

func (_m *Client) MergeShards(ctx context.Context, params *kinesis.MergeShardsInput, optFns ...func(*kinesis.Options)) (*kinesis.MergeShardsOutput, error)

MergeShards provides a mock function with given fields: ctx, params, optFns

func (*Client) PutRecord 

func (_m *Client) PutRecord(ctx context.Context, params *kinesis.PutRecordInput, optFns ...func(*kinesis.Options)) (*kinesis.PutRecordOutput, error)

PutRecord provides a mock function with given fields: ctx, params, optFns

func (*Client) PutRecords 

func (_m *Client) PutRecords(ctx context.Context, params *kinesis.PutRecordsInput, optFns ...func(*kinesis.Options)) (*kinesis.PutRecordsOutput, error)

PutRecords provides a mock function with given fields: ctx, params, optFns

func (*Client) RegisterStreamConsumer 

func (_m *Client) RegisterStreamConsumer(ctx context.Context, params *kinesis.RegisterStreamConsumerInput, optFns ...func(*kinesis.Options)) (*kinesis.RegisterStreamConsumerOutput, error)

RegisterStreamConsumer provides a mock function with given fields: ctx, params, optFns

func (*Client) RemoveTagsFromStream 

func (_m *Client) RemoveTagsFromStream(ctx context.Context, params *kinesis.RemoveTagsFromStreamInput, optFns ...func(*kinesis.Options)) (*kinesis.RemoveTagsFromStreamOutput, error)

RemoveTagsFromStream provides a mock function with given fields: ctx, params, optFns

func (*Client) SplitShard 

func (_m *Client) SplitShard(ctx context.Context, params *kinesis.SplitShardInput, optFns ...func(*kinesis.Options)) (*kinesis.SplitShardOutput, error)

SplitShard provides a mock function with given fields: ctx, params, optFns

func (*Client) StartStreamEncryption 

func (_m *Client) StartStreamEncryption(ctx context.Context, params *kinesis.StartStreamEncryptionInput, optFns ...func(*kinesis.Options)) (*kinesis.StartStreamEncryptionOutput, error)

StartStreamEncryption provides a mock function with given fields: ctx, params, optFns

func (*Client) StopStreamEncryption 

func (_m *Client) StopStreamEncryption(ctx context.Context, params *kinesis.StopStreamEncryptionInput, optFns ...func(*kinesis.Options)) (*kinesis.StopStreamEncryptionOutput, error)

StopStreamEncryption provides a mock function with given fields: ctx, params, optFns

func (*Client) SubscribeToShard 

func (_m *Client) SubscribeToShard(ctx context.Context, params *kinesis.SubscribeToShardInput, optFns ...func(*kinesis.Options)) (*kinesis.SubscribeToShardOutput, error)

SubscribeToShard provides a mock function with given fields: ctx, params, optFns

func (*Client) UpdateShardCount 

func (_m *Client) UpdateShardCount(ctx context.Context, params *kinesis.UpdateShardCountInput, optFns ...func(*kinesis.Options)) (*kinesis.UpdateShardCountOutput, error)

UpdateShardCount provides a mock function with given fields: ctx, params, optFns

func (*Client) UpdateStreamMode 

func (_m *Client) UpdateStreamMode(ctx context.Context, params *kinesis.UpdateStreamModeInput, optFns ...func(*kinesis.Options)) (*kinesis.UpdateStreamModeOutput, error)

UpdateStreamMode provides a mock function with given fields: ctx, params, optFns

type Client_AddTagsToStream_Call 

type Client_AddTagsToStream_Call struct {
	*mock.Call
}

Client_AddTagsToStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddTagsToStream'

func (*Client_AddTagsToStream_Call) Return 

func (_c *Client_AddTagsToStream_Call) Return(_a0 *kinesis.AddTagsToStreamOutput, _a1 error) *Client_AddTagsToStream_Call

func (*Client_AddTagsToStream_Call) Run 

func (_c *Client_AddTagsToStream_Call) Run(run func(ctx context.Context, params *kinesis.AddTagsToStreamInput, optFns ...func(*kinesis.Options))) *Client_AddTagsToStream_Call

func (*Client_AddTagsToStream_Call) RunAndReturn 

func (_c *Client_AddTagsToStream_Call) RunAndReturn(run func(context.Context, *kinesis.AddTagsToStreamInput, ...func(*kinesis.Options)) (*kinesis.AddTagsToStreamOutput, error)) *Client_AddTagsToStream_Call

type Client_CreateStream_Call 

type Client_CreateStream_Call struct {
	*mock.Call
}

Client_CreateStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateStream'

func (*Client_CreateStream_Call) Return 

func (_c *Client_CreateStream_Call) Return(_a0 *kinesis.CreateStreamOutput, _a1 error) *Client_CreateStream_Call

func (*Client_CreateStream_Call) Run 

func (_c *Client_CreateStream_Call) Run(run func(ctx context.Context, params *kinesis.CreateStreamInput, optFns ...func(*kinesis.Options))) *Client_CreateStream_Call

func (*Client_CreateStream_Call) RunAndReturn 

func (_c *Client_CreateStream_Call) RunAndReturn(run func(context.Context, *kinesis.CreateStreamInput, ...func(*kinesis.Options)) (*kinesis.CreateStreamOutput, error)) *Client_CreateStream_Call

type Client_DecreaseStreamRetentionPeriod_Call 

type Client_DecreaseStreamRetentionPeriod_Call struct {
	*mock.Call
}

Client_DecreaseStreamRetentionPeriod_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DecreaseStreamRetentionPeriod'

func (*Client_DecreaseStreamRetentionPeriod_Call) Return 

func (_c *Client_DecreaseStreamRetentionPeriod_Call) Return(_a0 *kinesis.DecreaseStreamRetentionPeriodOutput, _a1 error) *Client_DecreaseStreamRetentionPeriod_Call

func (*Client_DecreaseStreamRetentionPeriod_Call) Run 

func (_c *Client_DecreaseStreamRetentionPeriod_Call) Run(run func(ctx context.Context, params *kinesis.DecreaseStreamRetentionPeriodInput, optFns ...func(*kinesis.Options))) *Client_DecreaseStreamRetentionPeriod_Call

func (*Client_DecreaseStreamRetentionPeriod_Call) RunAndReturn 

func (_c *Client_DecreaseStreamRetentionPeriod_Call) RunAndReturn(run func(context.Context, *kinesis.DecreaseStreamRetentionPeriodInput, ...func(*kinesis.Options)) (*kinesis.DecreaseStreamRetentionPeriodOutput, error)) *Client_DecreaseStreamRetentionPeriod_Call

type Client_DeleteStream_Call 

type Client_DeleteStream_Call struct {
	*mock.Call
}

Client_DeleteStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteStream'

func (*Client_DeleteStream_Call) Return 

func (_c *Client_DeleteStream_Call) Return(_a0 *kinesis.DeleteStreamOutput, _a1 error) *Client_DeleteStream_Call

func (*Client_DeleteStream_Call) Run 

func (_c *Client_DeleteStream_Call) Run(run func(ctx context.Context, params *kinesis.DeleteStreamInput, optFns ...func(*kinesis.Options))) *Client_DeleteStream_Call

func (*Client_DeleteStream_Call) RunAndReturn 

func (_c *Client_DeleteStream_Call) RunAndReturn(run func(context.Context, *kinesis.DeleteStreamInput, ...func(*kinesis.Options)) (*kinesis.DeleteStreamOutput, error)) *Client_DeleteStream_Call

type Client_DeregisterStreamConsumer_Call 

type Client_DeregisterStreamConsumer_Call struct {
	*mock.Call
}

Client_DeregisterStreamConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeregisterStreamConsumer'

func (*Client_DeregisterStreamConsumer_Call) Return 

func (_c *Client_DeregisterStreamConsumer_Call) Return(_a0 *kinesis.DeregisterStreamConsumerOutput, _a1 error) *Client_DeregisterStreamConsumer_Call

func (*Client_DeregisterStreamConsumer_Call) Run 

func (_c *Client_DeregisterStreamConsumer_Call) Run(run func(ctx context.Context, params *kinesis.DeregisterStreamConsumerInput, optFns ...func(*kinesis.Options))) *Client_DeregisterStreamConsumer_Call

func (*Client_DeregisterStreamConsumer_Call) RunAndReturn 

func (_c *Client_DeregisterStreamConsumer_Call) RunAndReturn(run func(context.Context, *kinesis.DeregisterStreamConsumerInput, ...func(*kinesis.Options)) (*kinesis.DeregisterStreamConsumerOutput, error)) *Client_DeregisterStreamConsumer_Call

type Client_DescribeLimits_Call 

type Client_DescribeLimits_Call struct {
	*mock.Call
}

Client_DescribeLimits_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeLimits'

func (*Client_DescribeLimits_Call) Return 

func (_c *Client_DescribeLimits_Call) Return(_a0 *kinesis.DescribeLimitsOutput, _a1 error) *Client_DescribeLimits_Call

func (*Client_DescribeLimits_Call) Run 

func (_c *Client_DescribeLimits_Call) Run(run func(ctx context.Context, params *kinesis.DescribeLimitsInput, optFns ...func(*kinesis.Options))) *Client_DescribeLimits_Call

func (*Client_DescribeLimits_Call) RunAndReturn 

func (_c *Client_DescribeLimits_Call) RunAndReturn(run func(context.Context, *kinesis.DescribeLimitsInput, ...func(*kinesis.Options)) (*kinesis.DescribeLimitsOutput, error)) *Client_DescribeLimits_Call

type Client_DescribeStreamConsumer_Call 

type Client_DescribeStreamConsumer_Call struct {
	*mock.Call
}

Client_DescribeStreamConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeStreamConsumer'

func (*Client_DescribeStreamConsumer_Call) Return 

func (_c *Client_DescribeStreamConsumer_Call) Return(_a0 *kinesis.DescribeStreamConsumerOutput, _a1 error) *Client_DescribeStreamConsumer_Call

func (*Client_DescribeStreamConsumer_Call) Run 

func (_c *Client_DescribeStreamConsumer_Call) Run(run func(ctx context.Context, params *kinesis.DescribeStreamConsumerInput, optFns ...func(*kinesis.Options))) *Client_DescribeStreamConsumer_Call

func (*Client_DescribeStreamConsumer_Call) RunAndReturn 

func (_c *Client_DescribeStreamConsumer_Call) RunAndReturn(run func(context.Context, *kinesis.DescribeStreamConsumerInput, ...func(*kinesis.Options)) (*kinesis.DescribeStreamConsumerOutput, error)) *Client_DescribeStreamConsumer_Call

type Client_DescribeStreamSummary_Call 

type Client_DescribeStreamSummary_Call struct {
	*mock.Call
}

Client_DescribeStreamSummary_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeStreamSummary'

func (*Client_DescribeStreamSummary_Call) Return 

func (_c *Client_DescribeStreamSummary_Call) Return(_a0 *kinesis.DescribeStreamSummaryOutput, _a1 error) *Client_DescribeStreamSummary_Call

func (*Client_DescribeStreamSummary_Call) Run 

func (_c *Client_DescribeStreamSummary_Call) Run(run func(ctx context.Context, params *kinesis.DescribeStreamSummaryInput, optFns ...func(*kinesis.Options))) *Client_DescribeStreamSummary_Call

func (*Client_DescribeStreamSummary_Call) RunAndReturn 

func (_c *Client_DescribeStreamSummary_Call) RunAndReturn(run func(context.Context, *kinesis.DescribeStreamSummaryInput, ...func(*kinesis.Options)) (*kinesis.DescribeStreamSummaryOutput, error)) *Client_DescribeStreamSummary_Call

type Client_DescribeStream_Call 

type Client_DescribeStream_Call struct {
	*mock.Call
}

Client_DescribeStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DescribeStream'

func (*Client_DescribeStream_Call) Return 

func (_c *Client_DescribeStream_Call) Return(_a0 *kinesis.DescribeStreamOutput, _a1 error) *Client_DescribeStream_Call

func (*Client_DescribeStream_Call) Run 

func (_c *Client_DescribeStream_Call) Run(run func(ctx context.Context, params *kinesis.DescribeStreamInput, optFns ...func(*kinesis.Options))) *Client_DescribeStream_Call

func (*Client_DescribeStream_Call) RunAndReturn 

func (_c *Client_DescribeStream_Call) RunAndReturn(run func(context.Context, *kinesis.DescribeStreamInput, ...func(*kinesis.Options)) (*kinesis.DescribeStreamOutput, error)) *Client_DescribeStream_Call

type Client_DisableEnhancedMonitoring_Call 

type Client_DisableEnhancedMonitoring_Call struct {
	*mock.Call
}

Client_DisableEnhancedMonitoring_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DisableEnhancedMonitoring'

func (*Client_DisableEnhancedMonitoring_Call) Return 

func (_c *Client_DisableEnhancedMonitoring_Call) Return(_a0 *kinesis.DisableEnhancedMonitoringOutput, _a1 error) *Client_DisableEnhancedMonitoring_Call

func (*Client_DisableEnhancedMonitoring_Call) Run 

func (_c *Client_DisableEnhancedMonitoring_Call) Run(run func(ctx context.Context, params *kinesis.DisableEnhancedMonitoringInput, optFns ...func(*kinesis.Options))) *Client_DisableEnhancedMonitoring_Call

func (*Client_DisableEnhancedMonitoring_Call) RunAndReturn 

func (_c *Client_DisableEnhancedMonitoring_Call) RunAndReturn(run func(context.Context, *kinesis.DisableEnhancedMonitoringInput, ...func(*kinesis.Options)) (*kinesis.DisableEnhancedMonitoringOutput, error)) *Client_DisableEnhancedMonitoring_Call

type Client_EnableEnhancedMonitoring_Call 

type Client_EnableEnhancedMonitoring_Call struct {
	*mock.Call
}

Client_EnableEnhancedMonitoring_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnableEnhancedMonitoring'

func (*Client_EnableEnhancedMonitoring_Call) Return 

func (_c *Client_EnableEnhancedMonitoring_Call) Return(_a0 *kinesis.EnableEnhancedMonitoringOutput, _a1 error) *Client_EnableEnhancedMonitoring_Call

func (*Client_EnableEnhancedMonitoring_Call) Run 

func (_c *Client_EnableEnhancedMonitoring_Call) Run(run func(ctx context.Context, params *kinesis.EnableEnhancedMonitoringInput, optFns ...func(*kinesis.Options))) *Client_EnableEnhancedMonitoring_Call

func (*Client_EnableEnhancedMonitoring_Call) RunAndReturn 

func (_c *Client_EnableEnhancedMonitoring_Call) RunAndReturn(run func(context.Context, *kinesis.EnableEnhancedMonitoringInput, ...func(*kinesis.Options)) (*kinesis.EnableEnhancedMonitoringOutput, error)) *Client_EnableEnhancedMonitoring_Call

type Client_Expecter 

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

func (*Client_Expecter) AddTagsToStream 

func (_e *Client_Expecter) AddTagsToStream(ctx interface{}, params interface{}, optFns ...interface{}) *Client_AddTagsToStream_Call

AddTagsToStream is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.AddTagsToStreamInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) CreateStream 

func (_e *Client_Expecter) CreateStream(ctx interface{}, params interface{}, optFns ...interface{}) *Client_CreateStream_Call

CreateStream is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.CreateStreamInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DecreaseStreamRetentionPeriod 

func (_e *Client_Expecter) DecreaseStreamRetentionPeriod(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DecreaseStreamRetentionPeriod_Call

DecreaseStreamRetentionPeriod is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DecreaseStreamRetentionPeriodInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DeleteStream 

func (_e *Client_Expecter) DeleteStream(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DeleteStream_Call

DeleteStream is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DeleteStreamInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DeregisterStreamConsumer 

func (_e *Client_Expecter) DeregisterStreamConsumer(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DeregisterStreamConsumer_Call

DeregisterStreamConsumer is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DeregisterStreamConsumerInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DescribeLimits 

func (_e *Client_Expecter) DescribeLimits(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DescribeLimits_Call

DescribeLimits is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DescribeLimitsInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DescribeStream 

func (_e *Client_Expecter) DescribeStream(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DescribeStream_Call

DescribeStream is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DescribeStreamInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DescribeStreamConsumer 

func (_e *Client_Expecter) DescribeStreamConsumer(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DescribeStreamConsumer_Call

DescribeStreamConsumer is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DescribeStreamConsumerInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DescribeStreamSummary 

func (_e *Client_Expecter) DescribeStreamSummary(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DescribeStreamSummary_Call

DescribeStreamSummary is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DescribeStreamSummaryInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) DisableEnhancedMonitoring 

func (_e *Client_Expecter) DisableEnhancedMonitoring(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DisableEnhancedMonitoring_Call

DisableEnhancedMonitoring is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.DisableEnhancedMonitoringInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) EnableEnhancedMonitoring 

func (_e *Client_Expecter) EnableEnhancedMonitoring(ctx interface{}, params interface{}, optFns ...interface{}) *Client_EnableEnhancedMonitoring_Call

EnableEnhancedMonitoring is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.EnableEnhancedMonitoringInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) GetRecords 

func (_e *Client_Expecter) GetRecords(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetRecords_Call

GetRecords is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.GetRecordsInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) GetShardIterator 

func (_e *Client_Expecter) GetShardIterator(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetShardIterator_Call

GetShardIterator is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.GetShardIteratorInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) IncreaseStreamRetentionPeriod 

func (_e *Client_Expecter) IncreaseStreamRetentionPeriod(ctx interface{}, params interface{}, optFns ...interface{}) *Client_IncreaseStreamRetentionPeriod_Call

IncreaseStreamRetentionPeriod is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.IncreaseStreamRetentionPeriodInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) ListShards 

func (_e *Client_Expecter) ListShards(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ListShards_Call

ListShards is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.ListShardsInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) ListStreamConsumers 

func (_e *Client_Expecter) ListStreamConsumers(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ListStreamConsumers_Call

ListStreamConsumers is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.ListStreamConsumersInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) ListStreams 

func (_e *Client_Expecter) ListStreams(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ListStreams_Call

ListStreams is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.ListStreamsInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) ListTagsForStream 

func (_e *Client_Expecter) ListTagsForStream(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ListTagsForStream_Call

ListTagsForStream is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.ListTagsForStreamInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) MergeShards 

func (_e *Client_Expecter) MergeShards(ctx interface{}, params interface{}, optFns ...interface{}) *Client_MergeShards_Call

MergeShards is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.MergeShardsInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) PutRecord 

func (_e *Client_Expecter) PutRecord(ctx interface{}, params interface{}, optFns ...interface{}) *Client_PutRecord_Call

PutRecord is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.PutRecordInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) PutRecords 

func (_e *Client_Expecter) PutRecords(ctx interface{}, params interface{}, optFns ...interface{}) *Client_PutRecords_Call

PutRecords is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.PutRecordsInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) RegisterStreamConsumer 

func (_e *Client_Expecter) RegisterStreamConsumer(ctx interface{}, params interface{}, optFns ...interface{}) *Client_RegisterStreamConsumer_Call

RegisterStreamConsumer is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.RegisterStreamConsumerInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) RemoveTagsFromStream 

func (_e *Client_Expecter) RemoveTagsFromStream(ctx interface{}, params interface{}, optFns ...interface{}) *Client_RemoveTagsFromStream_Call

RemoveTagsFromStream is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.RemoveTagsFromStreamInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) SplitShard 

func (_e *Client_Expecter) SplitShard(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SplitShard_Call

SplitShard is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.SplitShardInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) StartStreamEncryption 

func (_e *Client_Expecter) StartStreamEncryption(ctx interface{}, params interface{}, optFns ...interface{}) *Client_StartStreamEncryption_Call

StartStreamEncryption is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.StartStreamEncryptionInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) StopStreamEncryption 

func (_e *Client_Expecter) StopStreamEncryption(ctx interface{}, params interface{}, optFns ...interface{}) *Client_StopStreamEncryption_Call

StopStreamEncryption is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.StopStreamEncryptionInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) SubscribeToShard 

func (_e *Client_Expecter) SubscribeToShard(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SubscribeToShard_Call

SubscribeToShard is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.SubscribeToShardInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) UpdateShardCount 

func (_e *Client_Expecter) UpdateShardCount(ctx interface{}, params interface{}, optFns ...interface{}) *Client_UpdateShardCount_Call

UpdateShardCount is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.UpdateShardCountInput
  • optFns ...func(*kinesis.Options)

func (*Client_Expecter) UpdateStreamMode 

func (_e *Client_Expecter) UpdateStreamMode(ctx interface{}, params interface{}, optFns ...interface{}) *Client_UpdateStreamMode_Call

UpdateStreamMode is a helper method to define mock.On call

  • ctx context.Context
  • params *kinesis.UpdateStreamModeInput
  • optFns ...func(*kinesis.Options)

type Client_GetRecords_Call 

type Client_GetRecords_Call struct {
	*mock.Call
}

Client_GetRecords_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecords'

func (*Client_GetRecords_Call) Return 

func (_c *Client_GetRecords_Call) Return(_a0 *kinesis.GetRecordsOutput, _a1 error) *Client_GetRecords_Call

func (*Client_GetRecords_Call) Run 

func (_c *Client_GetRecords_Call) Run(run func(ctx context.Context, params *kinesis.GetRecordsInput, optFns ...func(*kinesis.Options))) *Client_GetRecords_Call

func (*Client_GetRecords_Call) RunAndReturn 

func (_c *Client_GetRecords_Call) RunAndReturn(run func(context.Context, *kinesis.GetRecordsInput, ...func(*kinesis.Options)) (*kinesis.GetRecordsOutput, error)) *Client_GetRecords_Call

type Client_GetShardIterator_Call 

type Client_GetShardIterator_Call struct {
	*mock.Call
}

Client_GetShardIterator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetShardIterator'

func (*Client_GetShardIterator_Call) Return 

func (_c *Client_GetShardIterator_Call) Return(_a0 *kinesis.GetShardIteratorOutput, _a1 error) *Client_GetShardIterator_Call

func (*Client_GetShardIterator_Call) Run 

func (_c *Client_GetShardIterator_Call) Run(run func(ctx context.Context, params *kinesis.GetShardIteratorInput, optFns ...func(*kinesis.Options))) *Client_GetShardIterator_Call

func (*Client_GetShardIterator_Call) RunAndReturn 

func (_c *Client_GetShardIterator_Call) RunAndReturn(run func(context.Context, *kinesis.GetShardIteratorInput, ...func(*kinesis.Options)) (*kinesis.GetShardIteratorOutput, error)) *Client_GetShardIterator_Call

type Client_IncreaseStreamRetentionPeriod_Call 

type Client_IncreaseStreamRetentionPeriod_Call struct {
	*mock.Call
}

Client_IncreaseStreamRetentionPeriod_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IncreaseStreamRetentionPeriod'

func (*Client_IncreaseStreamRetentionPeriod_Call) Return 

func (_c *Client_IncreaseStreamRetentionPeriod_Call) Return(_a0 *kinesis.IncreaseStreamRetentionPeriodOutput, _a1 error) *Client_IncreaseStreamRetentionPeriod_Call

func (*Client_IncreaseStreamRetentionPeriod_Call) Run 

func (_c *Client_IncreaseStreamRetentionPeriod_Call) Run(run func(ctx context.Context, params *kinesis.IncreaseStreamRetentionPeriodInput, optFns ...func(*kinesis.Options))) *Client_IncreaseStreamRetentionPeriod_Call

func (*Client_IncreaseStreamRetentionPeriod_Call) RunAndReturn 

func (_c *Client_IncreaseStreamRetentionPeriod_Call) RunAndReturn(run func(context.Context, *kinesis.IncreaseStreamRetentionPeriodInput, ...func(*kinesis.Options)) (*kinesis.IncreaseStreamRetentionPeriodOutput, error)) *Client_IncreaseStreamRetentionPeriod_Call

type Client_ListShards_Call 

type Client_ListShards_Call struct {
	*mock.Call
}

Client_ListShards_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListShards'

func (*Client_ListShards_Call) Return 

func (_c *Client_ListShards_Call) Return(_a0 *kinesis.ListShardsOutput, _a1 error) *Client_ListShards_Call

func (*Client_ListShards_Call) Run 

func (_c *Client_ListShards_Call) Run(run func(ctx context.Context, params *kinesis.ListShardsInput, optFns ...func(*kinesis.Options))) *Client_ListShards_Call

func (*Client_ListShards_Call) RunAndReturn 

func (_c *Client_ListShards_Call) RunAndReturn(run func(context.Context, *kinesis.ListShardsInput, ...func(*kinesis.Options)) (*kinesis.ListShardsOutput, error)) *Client_ListShards_Call

type Client_ListStreamConsumers_Call 

type Client_ListStreamConsumers_Call struct {
	*mock.Call
}

Client_ListStreamConsumers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListStreamConsumers'

func (*Client_ListStreamConsumers_Call) Return 

func (_c *Client_ListStreamConsumers_Call) Return(_a0 *kinesis.ListStreamConsumersOutput, _a1 error) *Client_ListStreamConsumers_Call

func (*Client_ListStreamConsumers_Call) Run 

func (_c *Client_ListStreamConsumers_Call) Run(run func(ctx context.Context, params *kinesis.ListStreamConsumersInput, optFns ...func(*kinesis.Options))) *Client_ListStreamConsumers_Call

func (*Client_ListStreamConsumers_Call) RunAndReturn 

func (_c *Client_ListStreamConsumers_Call) RunAndReturn(run func(context.Context, *kinesis.ListStreamConsumersInput, ...func(*kinesis.Options)) (*kinesis.ListStreamConsumersOutput, error)) *Client_ListStreamConsumers_Call

type Client_ListStreams_Call 

type Client_ListStreams_Call struct {
	*mock.Call
}

Client_ListStreams_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListStreams'

func (*Client_ListStreams_Call) Return 

func (_c *Client_ListStreams_Call) Return(_a0 *kinesis.ListStreamsOutput, _a1 error) *Client_ListStreams_Call

func (*Client_ListStreams_Call) Run 

func (_c *Client_ListStreams_Call) Run(run func(ctx context.Context, params *kinesis.ListStreamsInput, optFns ...func(*kinesis.Options))) *Client_ListStreams_Call

func (*Client_ListStreams_Call) RunAndReturn 

func (_c *Client_ListStreams_Call) RunAndReturn(run func(context.Context, *kinesis.ListStreamsInput, ...func(*kinesis.Options)) (*kinesis.ListStreamsOutput, error)) *Client_ListStreams_Call

type Client_ListTagsForStream_Call 

type Client_ListTagsForStream_Call struct {
	*mock.Call
}

Client_ListTagsForStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTagsForStream'

func (*Client_ListTagsForStream_Call) Return 

func (_c *Client_ListTagsForStream_Call) Return(_a0 *kinesis.ListTagsForStreamOutput, _a1 error) *Client_ListTagsForStream_Call

func (*Client_ListTagsForStream_Call) Run 

func (_c *Client_ListTagsForStream_Call) Run(run func(ctx context.Context, params *kinesis.ListTagsForStreamInput, optFns ...func(*kinesis.Options))) *Client_ListTagsForStream_Call

func (*Client_ListTagsForStream_Call) RunAndReturn 

func (_c *Client_ListTagsForStream_Call) RunAndReturn(run func(context.Context, *kinesis.ListTagsForStreamInput, ...func(*kinesis.Options)) (*kinesis.ListTagsForStreamOutput, error)) *Client_ListTagsForStream_Call

type Client_MergeShards_Call 

type Client_MergeShards_Call struct {
	*mock.Call
}

Client_MergeShards_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'MergeShards'

func (*Client_MergeShards_Call) Return 

func (_c *Client_MergeShards_Call) Return(_a0 *kinesis.MergeShardsOutput, _a1 error) *Client_MergeShards_Call

func (*Client_MergeShards_Call) Run 

func (_c *Client_MergeShards_Call) Run(run func(ctx context.Context, params *kinesis.MergeShardsInput, optFns ...func(*kinesis.Options))) *Client_MergeShards_Call

func (*Client_MergeShards_Call) RunAndReturn 

func (_c *Client_MergeShards_Call) RunAndReturn(run func(context.Context, *kinesis.MergeShardsInput, ...func(*kinesis.Options)) (*kinesis.MergeShardsOutput, error)) *Client_MergeShards_Call

type Client_PutRecord_Call 

type Client_PutRecord_Call struct {
	*mock.Call
}

Client_PutRecord_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutRecord'

func (*Client_PutRecord_Call) Return 

func (_c *Client_PutRecord_Call) Return(_a0 *kinesis.PutRecordOutput, _a1 error) *Client_PutRecord_Call

func (*Client_PutRecord_Call) Run 

func (_c *Client_PutRecord_Call) Run(run func(ctx context.Context, params *kinesis.PutRecordInput, optFns ...func(*kinesis.Options))) *Client_PutRecord_Call

func (*Client_PutRecord_Call) RunAndReturn 

func (_c *Client_PutRecord_Call) RunAndReturn(run func(context.Context, *kinesis.PutRecordInput, ...func(*kinesis.Options)) (*kinesis.PutRecordOutput, error)) *Client_PutRecord_Call

type Client_PutRecords_Call 

type Client_PutRecords_Call struct {
	*mock.Call
}

Client_PutRecords_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutRecords'

func (*Client_PutRecords_Call) Return 

func (_c *Client_PutRecords_Call) Return(_a0 *kinesis.PutRecordsOutput, _a1 error) *Client_PutRecords_Call

func (*Client_PutRecords_Call) Run 

func (_c *Client_PutRecords_Call) Run(run func(ctx context.Context, params *kinesis.PutRecordsInput, optFns ...func(*kinesis.Options))) *Client_PutRecords_Call

func (*Client_PutRecords_Call) RunAndReturn 

func (_c *Client_PutRecords_Call) RunAndReturn(run func(context.Context, *kinesis.PutRecordsInput, ...func(*kinesis.Options)) (*kinesis.PutRecordsOutput, error)) *Client_PutRecords_Call

type Client_RegisterStreamConsumer_Call 

type Client_RegisterStreamConsumer_Call struct {
	*mock.Call
}

Client_RegisterStreamConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterStreamConsumer'

func (*Client_RegisterStreamConsumer_Call) Return 

func (_c *Client_RegisterStreamConsumer_Call) Return(_a0 *kinesis.RegisterStreamConsumerOutput, _a1 error) *Client_RegisterStreamConsumer_Call

func (*Client_RegisterStreamConsumer_Call) Run 

func (_c *Client_RegisterStreamConsumer_Call) Run(run func(ctx context.Context, params *kinesis.RegisterStreamConsumerInput, optFns ...func(*kinesis.Options))) *Client_RegisterStreamConsumer_Call

func (*Client_RegisterStreamConsumer_Call) RunAndReturn 

func (_c *Client_RegisterStreamConsumer_Call) RunAndReturn(run func(context.Context, *kinesis.RegisterStreamConsumerInput, ...func(*kinesis.Options)) (*kinesis.RegisterStreamConsumerOutput, error)) *Client_RegisterStreamConsumer_Call

type Client_RemoveTagsFromStream_Call 

type Client_RemoveTagsFromStream_Call struct {
	*mock.Call
}

Client_RemoveTagsFromStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveTagsFromStream'

func (*Client_RemoveTagsFromStream_Call) Return 

func (_c *Client_RemoveTagsFromStream_Call) Return(_a0 *kinesis.RemoveTagsFromStreamOutput, _a1 error) *Client_RemoveTagsFromStream_Call

func (*Client_RemoveTagsFromStream_Call) Run 

func (_c *Client_RemoveTagsFromStream_Call) Run(run func(ctx context.Context, params *kinesis.RemoveTagsFromStreamInput, optFns ...func(*kinesis.Options))) *Client_RemoveTagsFromStream_Call

func (*Client_RemoveTagsFromStream_Call) RunAndReturn 

func (_c *Client_RemoveTagsFromStream_Call) RunAndReturn(run func(context.Context, *kinesis.RemoveTagsFromStreamInput, ...func(*kinesis.Options)) (*kinesis.RemoveTagsFromStreamOutput, error)) *Client_RemoveTagsFromStream_Call

type Client_SplitShard_Call 

type Client_SplitShard_Call struct {
	*mock.Call
}

Client_SplitShard_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SplitShard'

func (*Client_SplitShard_Call) Return 

func (_c *Client_SplitShard_Call) Return(_a0 *kinesis.SplitShardOutput, _a1 error) *Client_SplitShard_Call

func (*Client_SplitShard_Call) Run 

func (_c *Client_SplitShard_Call) Run(run func(ctx context.Context, params *kinesis.SplitShardInput, optFns ...func(*kinesis.Options))) *Client_SplitShard_Call

func (*Client_SplitShard_Call) RunAndReturn 

func (_c *Client_SplitShard_Call) RunAndReturn(run func(context.Context, *kinesis.SplitShardInput, ...func(*kinesis.Options)) (*kinesis.SplitShardOutput, error)) *Client_SplitShard_Call

type Client_StartStreamEncryption_Call 

type Client_StartStreamEncryption_Call struct {
	*mock.Call
}

Client_StartStreamEncryption_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartStreamEncryption'

func (*Client_StartStreamEncryption_Call) Return 

func (_c *Client_StartStreamEncryption_Call) Return(_a0 *kinesis.StartStreamEncryptionOutput, _a1 error) *Client_StartStreamEncryption_Call

func (*Client_StartStreamEncryption_Call) Run 

func (_c *Client_StartStreamEncryption_Call) Run(run func(ctx context.Context, params *kinesis.StartStreamEncryptionInput, optFns ...func(*kinesis.Options))) *Client_StartStreamEncryption_Call

func (*Client_StartStreamEncryption_Call) RunAndReturn 

func (_c *Client_StartStreamEncryption_Call) RunAndReturn(run func(context.Context, *kinesis.StartStreamEncryptionInput, ...func(*kinesis.Options)) (*kinesis.StartStreamEncryptionOutput, error)) *Client_StartStreamEncryption_Call

type Client_StopStreamEncryption_Call 

type Client_StopStreamEncryption_Call struct {
	*mock.Call
}

Client_StopStreamEncryption_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopStreamEncryption'

func (*Client_StopStreamEncryption_Call) Return 

func (_c *Client_StopStreamEncryption_Call) Return(_a0 *kinesis.StopStreamEncryptionOutput, _a1 error) *Client_StopStreamEncryption_Call

func (*Client_StopStreamEncryption_Call) Run 

func (_c *Client_StopStreamEncryption_Call) Run(run func(ctx context.Context, params *kinesis.StopStreamEncryptionInput, optFns ...func(*kinesis.Options))) *Client_StopStreamEncryption_Call

func (*Client_StopStreamEncryption_Call) RunAndReturn 

func (_c *Client_StopStreamEncryption_Call) RunAndReturn(run func(context.Context, *kinesis.StopStreamEncryptionInput, ...func(*kinesis.Options)) (*kinesis.StopStreamEncryptionOutput, error)) *Client_StopStreamEncryption_Call

type Client_SubscribeToShard_Call 

type Client_SubscribeToShard_Call struct {
	*mock.Call
}

Client_SubscribeToShard_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubscribeToShard'

func (*Client_SubscribeToShard_Call) Return 

func (_c *Client_SubscribeToShard_Call) Return(_a0 *kinesis.SubscribeToShardOutput, _a1 error) *Client_SubscribeToShard_Call

func (*Client_SubscribeToShard_Call) Run 

func (_c *Client_SubscribeToShard_Call) Run(run func(ctx context.Context, params *kinesis.SubscribeToShardInput, optFns ...func(*kinesis.Options))) *Client_SubscribeToShard_Call

func (*Client_SubscribeToShard_Call) RunAndReturn 

func (_c *Client_SubscribeToShard_Call) RunAndReturn(run func(context.Context, *kinesis.SubscribeToShardInput, ...func(*kinesis.Options)) (*kinesis.SubscribeToShardOutput, error)) *Client_SubscribeToShard_Call

type Client_UpdateShardCount_Call 

type Client_UpdateShardCount_Call struct {
	*mock.Call
}

Client_UpdateShardCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateShardCount'

func (*Client_UpdateShardCount_Call) Return 

func (_c *Client_UpdateShardCount_Call) Return(_a0 *kinesis.UpdateShardCountOutput, _a1 error) *Client_UpdateShardCount_Call

func (*Client_UpdateShardCount_Call) Run 

func (_c *Client_UpdateShardCount_Call) Run(run func(ctx context.Context, params *kinesis.UpdateShardCountInput, optFns ...func(*kinesis.Options))) *Client_UpdateShardCount_Call

func (*Client_UpdateShardCount_Call) RunAndReturn 

func (_c *Client_UpdateShardCount_Call) RunAndReturn(run func(context.Context, *kinesis.UpdateShardCountInput, ...func(*kinesis.Options)) (*kinesis.UpdateShardCountOutput, error)) *Client_UpdateShardCount_Call

type Client_UpdateStreamMode_Call 

type Client_UpdateStreamMode_Call struct {
	*mock.Call
}

Client_UpdateStreamMode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateStreamMode'

func (*Client_UpdateStreamMode_Call) Return 

func (_c *Client_UpdateStreamMode_Call) Return(_a0 *kinesis.UpdateStreamModeOutput, _a1 error) *Client_UpdateStreamMode_Call

func (*Client_UpdateStreamMode_Call) Run 

func (_c *Client_UpdateStreamMode_Call) Run(run func(ctx context.Context, params *kinesis.UpdateStreamModeInput, optFns ...func(*kinesis.Options))) *Client_UpdateStreamMode_Call

func (*Client_UpdateStreamMode_Call) RunAndReturn 

func (_c *Client_UpdateStreamMode_Call) RunAndReturn(run func(context.Context, *kinesis.UpdateStreamModeInput, ...func(*kinesis.Options)) (*kinesis.UpdateStreamModeOutput, error)) *Client_UpdateStreamMode_Call

type Kinsumer 

type Kinsumer struct {
	mock.Mock
}

Kinsumer is an autogenerated mock type for the Kinsumer type

func NewKinsumer 

func NewKinsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *Kinsumer

NewKinsumer creates a new instance of Kinsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Kinsumer) EXPECT 

func (_m *Kinsumer) EXPECT() *Kinsumer_Expecter

func (*Kinsumer) Run 

func (_m *Kinsumer) Run(ctx context.Context, handler kinesis.MessageHandler) error

Run provides a mock function with given fields: ctx, handler

func (*Kinsumer) Stop 

func (_m *Kinsumer) Stop()

Stop provides a mock function with given fields:

type Kinsumer_Expecter 

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

func (*Kinsumer_Expecter) Run 

func (_e *Kinsumer_Expecter) Run(ctx interface{}, handler interface{}) *Kinsumer_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context
  • handler kinesis.MessageHandler

func (*Kinsumer_Expecter) Stop 

func (_e *Kinsumer_Expecter) Stop() *Kinsumer_Stop_Call

Stop is a helper method to define mock.On call

type Kinsumer_Run_Call 

type Kinsumer_Run_Call struct {
	*mock.Call
}

Kinsumer_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*Kinsumer_Run_Call) Return 

func (_c *Kinsumer_Run_Call) Return(_a0 error) *Kinsumer_Run_Call

func (*Kinsumer_Run_Call) Run 

func (_c *Kinsumer_Run_Call) Run(run func(ctx context.Context, handler kinesis.MessageHandler)) *Kinsumer_Run_Call

func (*Kinsumer_Run_Call) RunAndReturn 

func (_c *Kinsumer_Run_Call) RunAndReturn(run func(context.Context, kinesis.MessageHandler) error) *Kinsumer_Run_Call

type Kinsumer_Stop_Call 

type Kinsumer_Stop_Call struct {
	*mock.Call
}

Kinsumer_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*Kinsumer_Stop_Call) Return 

func (_c *Kinsumer_Stop_Call) Return() *Kinsumer_Stop_Call

func (*Kinsumer_Stop_Call) Run 

func (_c *Kinsumer_Stop_Call) Run(run func()) *Kinsumer_Stop_Call

func (*Kinsumer_Stop_Call) RunAndReturn 

func (_c *Kinsumer_Stop_Call) RunAndReturn(run func()) *Kinsumer_Stop_Call

type MessageHandler 

type MessageHandler struct {
	mock.Mock
}

MessageHandler is an autogenerated mock type for the MessageHandler type

func NewMessageHandler 

func NewMessageHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *MessageHandler

NewMessageHandler creates a new instance of MessageHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MessageHandler) Done 

func (_m *MessageHandler) Done()

Done provides a mock function with given fields:

func (*MessageHandler) EXPECT 

func (_m *MessageHandler) EXPECT() *MessageHandler_Expecter

func (*MessageHandler) Handle 

func (_m *MessageHandler) Handle(rawMessage []byte) error

Handle provides a mock function with given fields: rawMessage

type MessageHandler_Done_Call 

type MessageHandler_Done_Call struct {
	*mock.Call
}

MessageHandler_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*MessageHandler_Done_Call) Return 

func (_c *MessageHandler_Done_Call) Return() *MessageHandler_Done_Call

func (*MessageHandler_Done_Call) Run 

func (_c *MessageHandler_Done_Call) Run(run func()) *MessageHandler_Done_Call

func (*MessageHandler_Done_Call) RunAndReturn 

func (_c *MessageHandler_Done_Call) RunAndReturn(run func()) *MessageHandler_Done_Call

type MessageHandler_Expecter 

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

func (*MessageHandler_Expecter) Done 

func (_e *MessageHandler_Expecter) Done() *MessageHandler_Done_Call

Done is a helper method to define mock.On call

func (*MessageHandler_Expecter) Handle 

func (_e *MessageHandler_Expecter) Handle(rawMessage interface{}) *MessageHandler_Handle_Call

Handle is a helper method to define mock.On call

  • rawMessage []byte

type MessageHandler_Handle_Call 

type MessageHandler_Handle_Call struct {
	*mock.Call
}

MessageHandler_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'

func (*MessageHandler_Handle_Call) Return 

func (_c *MessageHandler_Handle_Call) Return(_a0 error) *MessageHandler_Handle_Call

func (*MessageHandler_Handle_Call) Run 

func (_c *MessageHandler_Handle_Call) Run(run func(rawMessage []byte)) *MessageHandler_Handle_Call

func (*MessageHandler_Handle_Call) RunAndReturn 

func (_c *MessageHandler_Handle_Call) RunAndReturn(run func([]byte) error) *MessageHandler_Handle_Call

type MetadataRepository 

type MetadataRepository struct {
	mock.Mock
}

MetadataRepository is an autogenerated mock type for the MetadataRepository type

func NewMetadataRepository 

func NewMetadataRepository(t interface {
	mock.TestingT
	Cleanup(func())
}) *MetadataRepository

NewMetadataRepository creates a new instance of MetadataRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MetadataRepository) AcquireShard 

func (_m *MetadataRepository) AcquireShard(ctx context.Context, shardId kinesis.ShardId) (kinesis.Checkpoint, error)

AcquireShard provides a mock function with given fields: ctx, shardId

func (*MetadataRepository) DeregisterClient 

func (_m *MetadataRepository) DeregisterClient(ctx context.Context) error

DeregisterClient provides a mock function with given fields: ctx

func (*MetadataRepository) EXPECT 

func (_m *MetadataRepository) EXPECT() *MetadataRepository_Expecter

func (*MetadataRepository) IsShardFinished 

func (_m *MetadataRepository) IsShardFinished(ctx context.Context, shardId kinesis.ShardId) (bool, error)

IsShardFinished provides a mock function with given fields: ctx, shardId

func (*MetadataRepository) RegisterClient 

func (_m *MetadataRepository) RegisterClient(ctx context.Context) (int, int, error)

RegisterClient provides a mock function with given fields: ctx

type MetadataRepository_AcquireShard_Call 

type MetadataRepository_AcquireShard_Call struct {
	*mock.Call
}

MetadataRepository_AcquireShard_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AcquireShard'

func (*MetadataRepository_AcquireShard_Call) Return 

func (_c *MetadataRepository_AcquireShard_Call) Return(_a0 kinesis.Checkpoint, _a1 error) *MetadataRepository_AcquireShard_Call

func (*MetadataRepository_AcquireShard_Call) Run 

func (_c *MetadataRepository_AcquireShard_Call) Run(run func(ctx context.Context, shardId kinesis.ShardId)) *MetadataRepository_AcquireShard_Call

func (*MetadataRepository_AcquireShard_Call) RunAndReturn 

func (_c *MetadataRepository_AcquireShard_Call) RunAndReturn(run func(context.Context, kinesis.ShardId) (kinesis.Checkpoint, error)) *MetadataRepository_AcquireShard_Call

type MetadataRepository_DeregisterClient_Call 

type MetadataRepository_DeregisterClient_Call struct {
	*mock.Call
}

MetadataRepository_DeregisterClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeregisterClient'

func (*MetadataRepository_DeregisterClient_Call) Return 

func (_c *MetadataRepository_DeregisterClient_Call) Return(_a0 error) *MetadataRepository_DeregisterClient_Call

func (*MetadataRepository_DeregisterClient_Call) Run 

func (_c *MetadataRepository_DeregisterClient_Call) Run(run func(ctx context.Context)) *MetadataRepository_DeregisterClient_Call

func (*MetadataRepository_DeregisterClient_Call) RunAndReturn 

func (_c *MetadataRepository_DeregisterClient_Call) RunAndReturn(run func(context.Context) error) *MetadataRepository_DeregisterClient_Call

type MetadataRepository_Expecter 

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

func (*MetadataRepository_Expecter) AcquireShard 

func (_e *MetadataRepository_Expecter) AcquireShard(ctx interface{}, shardId interface{}) *MetadataRepository_AcquireShard_Call

AcquireShard is a helper method to define mock.On call

  • ctx context.Context
  • shardId kinesis.ShardId

func (*MetadataRepository_Expecter) DeregisterClient 

func (_e *MetadataRepository_Expecter) DeregisterClient(ctx interface{}) *MetadataRepository_DeregisterClient_Call

DeregisterClient is a helper method to define mock.On call

  • ctx context.Context

func (*MetadataRepository_Expecter) IsShardFinished 

func (_e *MetadataRepository_Expecter) IsShardFinished(ctx interface{}, shardId interface{}) *MetadataRepository_IsShardFinished_Call

IsShardFinished is a helper method to define mock.On call

  • ctx context.Context
  • shardId kinesis.ShardId

func (*MetadataRepository_Expecter) RegisterClient 

func (_e *MetadataRepository_Expecter) RegisterClient(ctx interface{}) *MetadataRepository_RegisterClient_Call

RegisterClient is a helper method to define mock.On call

  • ctx context.Context

type MetadataRepository_IsShardFinished_Call 

type MetadataRepository_IsShardFinished_Call struct {
	*mock.Call
}

MetadataRepository_IsShardFinished_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsShardFinished'

func (*MetadataRepository_IsShardFinished_Call) Return 

func (_c *MetadataRepository_IsShardFinished_Call) Return(_a0 bool, _a1 error) *MetadataRepository_IsShardFinished_Call

func (*MetadataRepository_IsShardFinished_Call) Run 

func (_c *MetadataRepository_IsShardFinished_Call) Run(run func(ctx context.Context, shardId kinesis.ShardId)) *MetadataRepository_IsShardFinished_Call

func (*MetadataRepository_IsShardFinished_Call) RunAndReturn 

func (_c *MetadataRepository_IsShardFinished_Call) RunAndReturn(run func(context.Context, kinesis.ShardId) (bool, error)) *MetadataRepository_IsShardFinished_Call

type MetadataRepository_RegisterClient_Call 

type MetadataRepository_RegisterClient_Call struct {
	*mock.Call
}

MetadataRepository_RegisterClient_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterClient'

func (*MetadataRepository_RegisterClient_Call) Return 

func (_c *MetadataRepository_RegisterClient_Call) Return(clientIndex int, totalClients int, err error) *MetadataRepository_RegisterClient_Call

func (*MetadataRepository_RegisterClient_Call) Run 

func (_c *MetadataRepository_RegisterClient_Call) Run(run func(ctx context.Context)) *MetadataRepository_RegisterClient_Call

func (*MetadataRepository_RegisterClient_Call) RunAndReturn 

func (_c *MetadataRepository_RegisterClient_Call) RunAndReturn(run func(context.Context) (int, int, error)) *MetadataRepository_RegisterClient_Call

type RecordWriter 

type RecordWriter struct {
	mock.Mock
}

RecordWriter is an autogenerated mock type for the RecordWriter type

func NewRecordWriter 

func NewRecordWriter(t interface {
	mock.TestingT
	Cleanup(func())
}) *RecordWriter

NewRecordWriter creates a new instance of RecordWriter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RecordWriter) EXPECT 

func (_m *RecordWriter) EXPECT() *RecordWriter_Expecter

func (*RecordWriter) PutRecord 

func (_m *RecordWriter) PutRecord(ctx context.Context, record *kinesis.Record) error

PutRecord provides a mock function with given fields: ctx, record

func (*RecordWriter) PutRecords 

func (_m *RecordWriter) PutRecords(ctx context.Context, batch []*kinesis.Record) error

PutRecords provides a mock function with given fields: ctx, batch

type RecordWriter_Expecter 

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

func (*RecordWriter_Expecter) PutRecord 

func (_e *RecordWriter_Expecter) PutRecord(ctx interface{}, record interface{}) *RecordWriter_PutRecord_Call

PutRecord is a helper method to define mock.On call

  • ctx context.Context
  • record *kinesis.Record

func (*RecordWriter_Expecter) PutRecords 

func (_e *RecordWriter_Expecter) PutRecords(ctx interface{}, batch interface{}) *RecordWriter_PutRecords_Call

PutRecords is a helper method to define mock.On call

  • ctx context.Context
  • batch []*kinesis.Record

type RecordWriter_PutRecord_Call 

type RecordWriter_PutRecord_Call struct {
	*mock.Call
}

RecordWriter_PutRecord_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutRecord'

func (*RecordWriter_PutRecord_Call) Return 

func (_c *RecordWriter_PutRecord_Call) Return(_a0 error) *RecordWriter_PutRecord_Call

func (*RecordWriter_PutRecord_Call) Run 

func (_c *RecordWriter_PutRecord_Call) Run(run func(ctx context.Context, record *kinesis.Record)) *RecordWriter_PutRecord_Call

func (*RecordWriter_PutRecord_Call) RunAndReturn 

func (_c *RecordWriter_PutRecord_Call) RunAndReturn(run func(context.Context, *kinesis.Record) error) *RecordWriter_PutRecord_Call

type RecordWriter_PutRecords_Call 

type RecordWriter_PutRecords_Call struct {
	*mock.Call
}

RecordWriter_PutRecords_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutRecords'

func (*RecordWriter_PutRecords_Call) Return 

func (_c *RecordWriter_PutRecords_Call) Return(_a0 error) *RecordWriter_PutRecords_Call

func (*RecordWriter_PutRecords_Call) Run 

func (_c *RecordWriter_PutRecords_Call) Run(run func(ctx context.Context, batch []*kinesis.Record)) *RecordWriter_PutRecords_Call

func (*RecordWriter_PutRecords_Call) RunAndReturn 

func (_c *RecordWriter_PutRecords_Call) RunAndReturn(run func(context.Context, []*kinesis.Record) error) *RecordWriter_PutRecords_Call

type ShardReader 

type ShardReader struct {
	mock.Mock
}

ShardReader is an autogenerated mock type for the ShardReader type

func NewShardReader 

func NewShardReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShardReader

NewShardReader creates a new instance of ShardReader. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShardReader) EXPECT 

func (_m *ShardReader) EXPECT() *ShardReader_Expecter

func (*ShardReader) Run 

func (_m *ShardReader) Run(ctx context.Context, handler func([]byte) error) error

Run provides a mock function with given fields: ctx, handler

type ShardReader_Expecter 

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

func (*ShardReader_Expecter) Run 

func (_e *ShardReader_Expecter) Run(ctx interface{}, handler interface{}) *ShardReader_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context
  • handler func([]byte) error

type ShardReader_Run_Call 

type ShardReader_Run_Call struct {
	*mock.Call
}

ShardReader_Run_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Run'

func (*ShardReader_Run_Call) Return 

func (_c *ShardReader_Run_Call) Return(_a0 error) *ShardReader_Run_Call

func (*ShardReader_Run_Call) Run 

func (_c *ShardReader_Run_Call) Run(run func(ctx context.Context, handler func([]byte) error)) *ShardReader_Run_Call

func (*ShardReader_Run_Call) RunAndReturn 

func (_c *ShardReader_Run_Call) RunAndReturn(run func(context.Context, func([]byte) error) error) *ShardReader_Run_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.