kinesis

Documentation

Index

• func Create(cfg aws.Config, input *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)
• func Delete(cfg aws.Config, name string) (*kinesis.DeleteStreamOutput, error)
• func DescribeStream(cfg aws.Config, input *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)
• func Get(cfg aws.Config, name string) (*kinesis.GetRecordsOutput, error)
• func GetIter(cfg aws.Config, name string) (*kinesis.GetShardIteratorOutput, error)
• func GetIterSeq(cfg aws.Config, name, seq string) (*kinesis.GetShardIteratorOutput, error)
• func GetRecords(cfg aws.Config, shardIterator *string) (*kinesis.GetRecordsOutput, error)
• func GetStreamSeq(cfg aws.Config, name, seq string, num ...int32) (*kinesis.GetRecordsOutput, error)
• func List(cfg aws.Config, input *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)
• func Put(cfg aws.Config, input *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)
• func Register(cfg aws.Config, consumerName, streamARN string) (*kinesis.RegisterStreamConsumerOutput, error)
• func SubscribeToShard(cfg aws.Config, input *kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error)
• type P
  • func NewP(name string) *P
  • func (p *P) Create() (*kinesis.CreateStreamOutput, error)
  • func (p *P) Delete() (*kinesis.DeleteStreamOutput, error)
  • func (p *P) DescribeStream() (*kinesis.DescribeStreamOutput, error)
  • func (p *P) Get() (*kinesis.GetRecordsOutput, error)
  • func (p *P) List() (*kinesis.ListStreamsOutput, error)
  • func (p *P) Name(name string) *P
  • func (p *P) Put(key string, data []byte) (*kinesis.PutRecordOutput, error)
  • func (p *P) Register(consumerName string, streamARN string) (*kinesis.RegisterStreamConsumerOutput, error)
  • func (p *P) StreamARN() (*string, error)
  • func (p *P) SubscribeToShard() (*kinesis.SubscribeToShardOutput, error)

Functions

func Create

func Create(cfg aws.Config, input *kinesis.CreateStreamInput) (*kinesis.CreateStreamOutput, error)

func Delete

func Delete(cfg aws.Config, name string) (*kinesis.DeleteStreamOutput, error)

func DescribeStream

func DescribeStream(cfg aws.Config, input *kinesis.DescribeStreamInput) (*kinesis.DescribeStreamOutput, error)

func Get

func Get(cfg aws.Config, name string) (*kinesis.GetRecordsOutput, error)

func GetIter

func GetIter(cfg aws.Config, name string) (*kinesis.GetShardIteratorOutput, error)

func GetIterSeq

func GetIterSeq(cfg aws.Config, name, seq string) (*kinesis.GetShardIteratorOutput, error)

func GetRecords

func GetRecords(cfg aws.Config, shardIterator *string) (*kinesis.GetRecordsOutput, error)

func GetStreamSeq

func GetStreamSeq(cfg aws.Config, name, seq string, num ...int32) (*kinesis.GetRecordsOutput, error)

func List

func List(cfg aws.Config, input *kinesis.ListStreamsInput) (*kinesis.ListStreamsOutput, error)

func Put

func Put(cfg aws.Config, input *kinesis.PutRecordInput) (*kinesis.PutRecordOutput, error)

func Register

func Register(cfg aws.Config, consumerName, streamARN string) (*kinesis.RegisterStreamConsumerOutput, error)

func SubscribeToShard

func SubscribeToShard(cfg aws.Config, input *kinesis.SubscribeToShardInput) (*kinesis.SubscribeToShardOutput, error)

Types

type P

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

func NewP

func NewP(name string) *P

func (*P) Create

func (p *P) Create() (*kinesis.CreateStreamOutput, error)

func (*P) Delete

func (p *P) Delete() (*kinesis.DeleteStreamOutput, error)

func (*P) DescribeStream

func (p *P) DescribeStream() (*kinesis.DescribeStreamOutput, error)

func (*P) Get

func (p *P) Get() (*kinesis.GetRecordsOutput, error)

func (*P) List

func (p *P) List() (*kinesis.ListStreamsOutput, error)

func (*P) Name

func (p *P) Name(name string) *P

func (*P) Put

func (p *P) Put(key string, data []byte) (*kinesis.PutRecordOutput, error)

func (*P) Register

func (p *P) Register(consumerName string, streamARN string) (*kinesis.RegisterStreamConsumerOutput, error)

func (*P) StreamARN

func (p *P) StreamARN() (*string, error)

func (*P) SubscribeToShard

func (p *P) SubscribeToShard() (*kinesis.SubscribeToShardOutput, error)