code: func NewLogAggregatorDecorator(
  	kinesisResource *gocf.KinesisStream,
  	kinesisMapping *sparta.EventSourceMapping,
  	relay *sparta.LambdaAWSInfo) *LogAggregatorDecorator {
  
  	return &LogAggregatorDecorator{
  		kinesisStreamResourceName: logAggregatorResName("Kinesis"),
  		kinesisResource:           kinesisResource,
  		kinesisMapping:            kinesisMapping,
  		iamRoleNameResourceName:   logAggregatorResName("IAMRole"),
  		logRelay:                  relay,
  	}
  }
docs: // NewLogAggregatorDecorator returns a ServiceDecoratorHook that registers a Kinesis
  // stream lambda log aggregator