mock

Documentation

Index

• type DescribeDeliveryStreamFunc
• type DescribeStreamFunc
• type FirehoseMock
  • func (f *FirehoseMock) DescribeDeliveryStream(input *firehose.DescribeDeliveryStreamInput) (*firehose.DescribeDeliveryStreamOutput, error)
  • func (f *FirehoseMock) PutRecordBatch(input *firehose.PutRecordBatchInput) (*firehose.PutRecordBatchOutput, error)
• type KinesisMock
  • func (k *KinesisMock) DescribeStream(input *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
  • func (k *KinesisMock) PutRecords(input *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
• type PutRecordBatchFunc
• type PutRecordsFunc

Types

type DescribeDeliveryStreamFunc

type DescribeDeliveryStreamFunc func(input *firehose.DescribeDeliveryStreamInput) (*firehose.DescribeDeliveryStreamOutput, error)

type DescribeStreamFunc

type DescribeStreamFunc func(input *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

type FirehoseMock

type FirehoseMock struct {
	firehoseiface.FirehoseAPI

	PutRecordBatchFunc                PutRecordBatchFunc
	PutRecordBatchFuncInvoked         bool
	DescribeDeliveryStreamFunc        DescribeDeliveryStreamFunc
	DescribeDeliveryStreamFuncInvoked bool
}

func (*FirehoseMock) DescribeDeliveryStream

func (f *FirehoseMock) DescribeDeliveryStream(input *firehose.DescribeDeliveryStreamInput) (*firehose.DescribeDeliveryStreamOutput, error)

func (*FirehoseMock) PutRecordBatch

func (f *FirehoseMock) PutRecordBatch(input *firehose.PutRecordBatchInput) (*firehose.PutRecordBatchOutput, error)

type KinesisMock

type KinesisMock struct {
	kinesisiface.KinesisAPI

	PutRecordsFunc            PutRecordsFunc
	PutRecordsFuncInvoked     bool
	DescribeStreamFunc        DescribeStreamFunc
	DescribeStreamFuncInvoked bool
}

func (*KinesisMock) DescribeStream

func (k *KinesisMock) DescribeStream(input *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

func (*KinesisMock) PutRecords

func (k *KinesisMock) PutRecords(input *kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)

type PutRecordBatchFunc

type PutRecordBatchFunc func(*firehose.PutRecordBatchInput) (*firehose.PutRecordBatchOutput, error)

type PutRecordsFunc

type PutRecordsFunc func(*kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)