code: func (kinesis *Kinesis) CreateStream(StreamName string, ShardCount int) error {
  	params := makeParams("CreateStream")
  	requestParams := struct {
  		StreamName string
  		ShardCount int
  	}{
  		StreamName,
  		ShardCount,
  	}
  	err := kinesis.query(params, requestParams, nil)
  	if err != nil {
  		return err
  	}
  	return nil
  }
docs: // CreateStream adds a new Amazon Kinesis stream to your AWS account
  // StreamName is a name of stream, ShardCount is number of shards
  // more info http://docs.aws.amazon.com/kinesis/latest/APIReference/API_CreateStream.html