Method Initialize

input/kcl.go:289–296

Initialize is invoked by the Amazon Kinesis Client Library before data records are delivered to the RecordProcessor instance (via processRecords).

(input *interfaces.InitializationInput)

// Initialize is invoked by the Amazon Kinesis Client Library before data
// records are delivered to the RecordProcessor instance (via processRecords).
func (p *recordProcessor) Initialize(input *interfaces.InitializationInput) {
	p.shardID = input.ShardId
	p.tags = []string{fmt.Sprintf("shard:%s", p.shardID)}
	log.WithFields(log.Fields{
		"shard":      input.ShardId,
		"checkpoint": aws.StringValue(input.ExtendedSequenceNumber.SequenceNumber)}).
		Info("Initializing a new RecordProcessor")
}

// ProcessRecords process data records. vmware kcl will invoke this method to
// deliver data records.