Method Shutdown

input/kcl.go:272–285

Shutdown is invoked by the Amazon Kinesis Client Library to indicate it will no longer send data records to this RecordProcessor instance.

(input *interfaces.ShutdownInput)

// Shutdown is invoked by the Amazon Kinesis Client Library to indicate it will
// no longer send data records to this RecordProcessor instance.
func (p *recordProcessor) Shutdown(input *interfaces.ShutdownInput) {
	log.WithFields(log.Fields{
		"shard":  p.shardID,
		"reason": aws.StringValue(interfaces.ShutdownReasonMessage(input.ShutdownReason)),
	}).Info("Shutting down a KCL record processor")

	// The shard is closed and completely read, so we checkpoint the nil value that informs
	// vmware-go-kcl about that fact
	if input.ShutdownReason == interfaces.TERMINATE {
		if err := input.Checkpointer.Checkpoint(nil); err != nil {
			log.Errorf("Error checkpointing nil: %v", err)
		}
	}
}

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