kinesis

type Auth interface {
	// KeyForSigning return an access key / secret / token appropriate for signing at time now,
	// which as the name suggests, is usually now.
	KeyForSigning(now time.Time) (*SigningKey, error)
}

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

type DescribeDeliveryStreamResp struct {
	DeliveryStreamDescription struct {
		CreateTimestamp      float32
		DeliveryStreamARN    string
		DeliveryStreamName   string
		DeliveryStreamStatus string
		Destinations         []DestinationsResp
		HasMoreDestinations  bool
		LastUpdatedTimestamp int
		VersionId            string
	}
}

type DescribeStreamResp struct {
	StreamDescription struct {
		HasMoreShards bool
		Shards        []DescribeStreamShards
		StreamARN     string
		StreamName    string
		StreamStatus  string
	}
}

type DescribeStreamShards struct {
	AdjacentParentShardId string
	HashKeyRange          struct {
		EndingHashKey   string
		StartingHashKey string
	}
	ParentShardId       string
	SequenceNumberRange struct {
		EndingSequenceNumber   string
		StartingSequenceNumber string
	}
	ShardId string
}

type DestinationsResp struct {
	DestinationId                  string
	RedshiftDestinationDescription RedshiftDestinationDescriptionResp
	S3DestinationDescription       S3DestinationDescriptionResp
}

type Error struct {
	// HTTP status code (200, 403, ...)
	StatusCode int
	// error code ("UnsupportedOperation", ...)
	Code string
	// The human-oriented error message
	Message   string
	RequestId string
}

type GetRecordsRecords struct {
	ApproximateArrivalTimestamp float64
	Data                        []byte
	PartitionKey                string
	SequenceNumber              string
}

type GetRecordsResp struct {
	MillisBehindLatest int64
	NextShardIterator  string
	Records            []GetRecordsRecords
}

type GetShardIteratorResp struct {
	ShardIterator string
}

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

type KinesisClient interface {
	CreateStream(StreamName string, ShardCount int) error
	DeleteStream(StreamName string) error
	DescribeStream(args *RequestArgs) (resp *DescribeStreamResp, err error)
	DescribeDeliveryStream(args *RequestArgs) (resp *DescribeDeliveryStreamResp, err error)
	GetRecords(args *RequestArgs) (resp *GetRecordsResp, err error)
	GetShardIterator(args *RequestArgs) (resp *GetShardIteratorResp, err error)
	ListStreams(args *RequestArgs) (resp *ListStreamsResp, err error)
	MergeShards(args *RequestArgs) error
	PutRecord(args *RequestArgs) (resp *PutRecordResp, err error)
	PutRecords(args *RequestArgs) (resp *PutRecordsResp, err error)
	PutRecordBatch(args *RequestArgs) (resp *PutRecordBatchResp, err error)
	SplitShard(args *RequestArgs) error
}

type ListStreamsResp struct {
	HasMoreStreams bool
	StreamNames    []string
}

type PutRecordBatchResp struct {
	FailedPutCount   int
	RequestResponses []PutRecordBatchResponses
}

type PutRecordBatchResponses struct {
	ErrorCode    string
	ErrorMessage string
	RecordId     string
}

type PutRecordResp struct {
	SequenceNumber string
	ShardId        string
}

type PutRecordsResp struct {
	FailedRecordCount int
	Records           []PutRecordsRespRecord
}

type PutRecordsRespRecord struct {
	ErrorCode      string
	ErrorMessage   string
	SequenceNumber string
	ShardId        string
}

type Record struct {
	Data         []byte
	PartitionKey string
}

type RedshiftDestinationDescriptionResp struct {
	ClusterJDBCURL string
	CopyCommand    struct {
		CopyOptions      string
		DataTableColumns string
		DataTableName    string
	}
	RoleARN                  string
	S3DestinationDescription S3DestinationDescriptionResp
	Username                 string
}

type RequestArgs struct {
	Records []Record
	// contains filtered or unexported fields
}

type S3DestinationDescriptionResp struct {
	BucketARN      string
	BufferingHints struct {
		IntervalInSeconds int
		SizeInMBs         int
	}
	CompressionFormat       string
	EncryptionConfiguration struct {
		KMSEncryptionConfig struct {
			AWSKMSKeyARN string
		}
		NoEncryptionConfig string
	}
	Prefix  string
	RoleARN string
}

type Service struct {
	// Name is the name of the service being used (i.e. iam, etc)
	Name string

	// Region is the region you want to communicate with the service through. (i.e. us-east-1)
	Region string
}

type SigningKey struct {
	AccessKeyId     string
	SecretAccessKey string
	SessionToken    string
}