interface.go 2.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. // THIS FILE IS AUTOMATICALLY GENERATED. DO NOT EDIT.
  2. // Package kinesisiface provides an interface for the Amazon Kinesis.
  3. package kinesisiface
  4. import (
  5. "github.com/aws/aws-sdk-go/aws/request"
  6. "github.com/aws/aws-sdk-go/service/kinesis"
  7. )
  8. // KinesisAPI is the interface type for kinesis.Kinesis.
  9. type KinesisAPI interface {
  10. AddTagsToStreamRequest(*kinesis.AddTagsToStreamInput) (*request.Request, *kinesis.AddTagsToStreamOutput)
  11. AddTagsToStream(*kinesis.AddTagsToStreamInput) (*kinesis.AddTagsToStreamOutput, error)
  12. CreateStreamRequest(*kinesis.CreateStreamInput) (*request.Request, *kinesis.CreateStreamOutput)
  13. CreateStream(*kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
  14. DeleteStreamRequest(*kinesis.DeleteStreamInput) (*request.Request, *kinesis.DeleteStreamOutput)
  15. DeleteStream(*kinesis.DeleteStreamInput) (*kinesis.DeleteStreamOutput, error)
  16. DescribeStreamRequest(*kinesis.DescribeStreamInput) (*request.Request, *kinesis.DescribeStreamOutput)
  17. DescribeStream(*kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
  18. DescribeStreamPages(*kinesis.DescribeStreamInput, func(*kinesis.DescribeStreamOutput, bool) bool) error
  19. GetRecordsRequest(*kinesis.GetRecordsInput) (*request.Request, *kinesis.GetRecordsOutput)
  20. GetRecords(*kinesis.GetRecordsInput) (*kinesis.GetRecordsOutput, error)
  21. GetShardIteratorRequest(*kinesis.GetShardIteratorInput) (*request.Request, *kinesis.GetShardIteratorOutput)
  22. GetShardIterator(*kinesis.GetShardIteratorInput) (*kinesis.GetShardIteratorOutput, error)
  23. ListStreamsRequest(*kinesis.ListStreamsInput) (*request.Request, *kinesis.ListStreamsOutput)
  24. ListStreams(*kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
  25. ListStreamsPages(*kinesis.ListStreamsInput, func(*kinesis.ListStreamsOutput, bool) bool) error
  26. ListTagsForStreamRequest(*kinesis.ListTagsForStreamInput) (*request.Request, *kinesis.ListTagsForStreamOutput)
  27. ListTagsForStream(*kinesis.ListTagsForStreamInput) (*kinesis.ListTagsForStreamOutput, error)
  28. MergeShardsRequest(*kinesis.MergeShardsInput) (*request.Request, *kinesis.MergeShardsOutput)
  29. MergeShards(*kinesis.MergeShardsInput) (*kinesis.MergeShardsOutput, error)
  30. PutRecordRequest(*kinesis.PutRecordInput) (*request.Request, *kinesis.PutRecordOutput)
  31. PutRecord(*kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
  32. PutRecordsRequest(*kinesis.PutRecordsInput) (*request.Request, *kinesis.PutRecordsOutput)
  33. PutRecords(*kinesis.PutRecordsInput) (*kinesis.PutRecordsOutput, error)
  34. RemoveTagsFromStreamRequest(*kinesis.RemoveTagsFromStreamInput) (*request.Request, *kinesis.RemoveTagsFromStreamOutput)
  35. RemoveTagsFromStream(*kinesis.RemoveTagsFromStreamInput) (*kinesis.RemoveTagsFromStreamOutput, error)
  36. SplitShardRequest(*kinesis.SplitShardInput) (*request.Request, *kinesis.SplitShardOutput)
  37. SplitShard(*kinesis.SplitShardInput) (*kinesis.SplitShardOutput, error)
  38. }